1回答
我在SQL 2012中使用合并复制。我的一些合并文章使用列级跟踪。我正试图了解如何使用MSmerge_contents表中的“沿袭”和“MSmerge_contents”字段来计算数据库中特定行中哪些列发生了更改。
浏览 0提问于2012-11-02得票数 0
回答已采纳
我正在使用Flink 1.8中的Flink SQL API。我有两个流表Table1和Table2。如果我们将receivedTime定义为在表中接收数据的时间，我希望加入Table1和Table2 (在某些id上)，只保留Table1.receivedTime > Table2.receivedTime首先，我尝试使用Flink SQL CURRENT_TIMESTAMP来完成这个任务：
N
浏览 3提问于2019-12-12得票数 0
回答已采纳
下面是我使用flink创建的表的create语句。现在，我想通过添加一个新列来修改这个表。以下是我尝试从flink作业运行的ALTER命令： 1.ALTER TABLE event_kafkaTable ADD test6 string; 这两个命令都抛出了Flink SQL解析器异常。Flink的官方网站https://ci.apache.org/projects/flink
浏览 184提问于2020-11-25得票数 0
回答已采纳
当我们在作为SQL Server数据库表的源的Flink SQL CLI中选择任何表时，为什么Flink作业在从数据库表中获取所有记录后“完成”？有没有可能让它“运行”，这样它就可以从数据库表中获取最新的数据？
浏览 4提问于2020-12-25得票数 1
1回答
我使用Azure权限进行数据治理和数据沿袭。我们在数据体系结构中使用Databricks，但是不存在任何本机支持来捕获Databricks的数据沿袭。我找到了以下链接，这些链接将允许您在Azure权限中创建自定义进程。
有人能让我知道最近是否有任何方法在Azure权限范围内使用Databricks实现数据沿袭？
浏览 5提问于2022-05-11得票数 0
更多细节:我在一个(普通的)数据库中有几个表，从数千行到数百万行不等，而且每个表都与其他的表有多到多(M2M)的关系。大多数级别上的对象和关系经常发生变化，我需要次秒延迟才能从“已更改的记录或关系”重新计算任何带有更改的扁平配置文件，这样我就可以非常快地将更新推到主机上。
这是流Flink / Beam的合适用例吗？我要坚持的部分是，在批处理模式下，PCollections都是“完整的”，因为我总是可以将一个表中的所有记录与另一个表<
浏览 2提问于2022-03-27得票数 1
回答已采纳
1回答
ZetaSQL -解析功能和功能
、、、、
我目前正在开发一个将部署在google云空间中的血统系统，目标是使用审计日志提取和解析从BigQuery执行的SQL查询，并从中创建一个谱系。我探索了几个现有的产品，但最终决定自己开发。我偶然发现了谷歌的POC和文档()的数据沿袭，这使我探索了zetaSQL的使用。, simpleCatalog从其中提取引用的表和输出列。当引用表已经从查询中可用时，为什么zetaSQL需要表目录的
浏览 15提问于2022-08-16得票数 0
回答已采纳
我想知道一般对查询和表使用了多少状态。首先，我使用Flink SQL处理来自Kafka主题的消息： country STRING,) WITH (状态管理的是这样说的：
那么，我是否正确地理解Flink没有从</
浏览 8提问于2021-12-11得票数 0
回答已采纳
2回答
Flink的嵌套输出
、、、
我正在使用Flink SQL处理Kafka流，其中每条消息都是从kafka中提取的，使用flink sql处理，然后推回到Kafka中。我想要一个嵌套的输出，其中输入是扁平的，输出是嵌套的。例如，我的输入是 {'StudentName':'ABC','StudentAge':33} 并希望输出为 {'Student':{'Name':'ABC',&#x
浏览 56提问于2019-01-04得票数 0
我想使用Flink对Postgresql中的数据进行一些分析。我应该如何和在哪里给出端口地址，用户名和密码。我正在尝试使用链接：中提到的表源。
浏览 0提问于2018-06-21得票数 1
回答已采纳
我有一台Flink服务器运行在一台计算机上。我想创建一个java web应用程序，它可以部署SQL(源代码创建SQL.，Sink创建SQL.)。然后插入Sink选择field1，.从源表)如何使用Table . flink-table-common-1.15.2.jar) 对远程Flink服务器执行上述SQL，应用程序将显示缺少ja
浏览 3提问于2022-10-14得票数 0
我有两个要进行间隔连接的流，事件类型是按如下方式定义的案例类，tradeDate的类型是java.sql.Timestamp case class Stock(id: String, tradeDateStockNameChanging(id: String, name: String, tradeDate: Timestamp) 当我运行下面的应用程序时，抛出了一个异常，如下所示，我不知道它在说什么，也不知道如何解决问题used as event-time timestamp for the DataStream by casting all other
浏览 50提问于2021-01-02得票数 0
回答已采纳
我正在尝试创建一个过程，它可以创建一个没有特定列数的表。我的查询返回值3，这意味着它需要3列(必须是动态的)。我已经创建了一个@variable来设置表的名称字符串，但是我不知道如何构造CREATE TABLE语句来实际创建包含该字符串中的列的表。
任何形式的帮助都会被感谢的家伙。
浏览 3提问于2012-11-27得票数 0
我的纳税表中有身份证，税务，保险栏如下类似地，我有一个具有相同列的Insurance表现在，我希望查询的结果可以从两个表中提取所有ID，从纳税表和保险表中只提取Tax列，并使其他值为空，如下所示如何在SQL中实现这一点？
浏览 0提问于2018-06-28得票数 1
回答已采纳
Apache Flink 1.11.0 Python表API目录: postgresql 通过Table API抛出UUID数据类型unsupportedOperatorException，从包含UUID数据类型列的postgresql Catalog表中读取和写入数据。如何处理pyFlink中的UUID数据类型？
浏览 26提问于2020-10-18得票数 0
我已经创建了一个SSIS包，用于从名为.mdb的访问表( TmShipping )中提取数据，并将数据加载到一个SQL表中--比如说，TmShippingImport，这个SQL表有Id和importedDate：第一次执行SSIS包时，将每
浏览 1提问于2018-02-09得票数 0
我试图在我的一个项目中使用Apache的表概念来实时组合来自多个来源的数据。不幸的是，我的团队成员都是Node.JS开发人员。因此，我正在寻找从NodeJS连接到Flink并从它进行查询的可能方法。在SQL的中，有人提到
SQL客户端旨在提供一种编写、调试表程序和将表程序提交到Flink集群的简单方法，而无需一行Java或Scala代码。SQL客户端CLI允许检索和可视化命令行上运行的分布式应用程
浏览 15提问于2022-07-19得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
