apache-flink - 从外部应用程序查询 Flink 动态表

Question

我有动态表 API 的 Flink 工作。我想从外部源/应用程序（如 jdbc/rest api 等）查询结果表。请帮忙。

标签： apache-flink

Answer 1

您需要做的是通过连接存储结果并使其可用于查询的 TableSink 来在某处具体化结果表。例如，您可以使用JDBC或HBase连接器。

这是必要的，因为通常“结果表”并不真正存在。例如，对于仅涉及投影和窗口聚合的查询，结果从 Flink 流出，但实际上并未保留在 Flink 中。