Apache Flink Table 1.4:可以在 Table 上执行外部 SQL 吗?
Apache Flink Table 1.4: External SQL execution on Table possible?
是否可以在不上传 .jar 的情况下从外部查询现有 StreamTable 获取执行环境并检索 table 环境?我一直在等待 Apache Flink Table 1.4 发布,因为它具有动态(连续)table 功能。我期待其他东西,我认为可以在运行时更改 table 并修改其参数。为了进行一些实时查询,而不是在数据流之上定义(连续或仅附加)数据库视图。我知道我可以将我的 table 导出到某个数据库并使用 SQL 动态查询该数据库,但这是一种尴尬的行为。 Flink 的美妙之处在于一切都是实时的,一切都是流,那么是否可以从一些外部程序实时查询 Flink table?
不,目前不支持。
在将流式查询的结果 table 存储为可查询状态方面已经开展了一些工作。这将允许对固定键属性进行点(键查找)查询。 Flink 1.5 可能会提供此功能。
没有具体的计划来支持 SQL 对流式 SQL(或 Table API)查询生成的动态 table 查询。您必须将 table 发送到 RDBMS 并从那里查询数据。
是否可以在不上传 .jar 的情况下从外部查询现有 StreamTable 获取执行环境并检索 table 环境?我一直在等待 Apache Flink Table 1.4 发布,因为它具有动态(连续)table 功能。我期待其他东西,我认为可以在运行时更改 table 并修改其参数。为了进行一些实时查询,而不是在数据流之上定义(连续或仅附加)数据库视图。我知道我可以将我的 table 导出到某个数据库并使用 SQL 动态查询该数据库,但这是一种尴尬的行为。 Flink 的美妙之处在于一切都是实时的,一切都是流,那么是否可以从一些外部程序实时查询 Flink table?
不,目前不支持。
在将流式查询的结果 table 存储为可查询状态方面已经开展了一些工作。这将允许对固定键属性进行点(键查找)查询。 Flink 1.5 可能会提供此功能。
没有具体的计划来支持 SQL 对流式 SQL(或 Table API)查询生成的动态 table 查询。您必须将 table 发送到 RDBMS 并从那里查询数据。