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

Question

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

Answer 1

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

这是必要的，因为一般来说，"结果表"实际上并不存在。例如，对于仅涉及投影和窗口聚合的查询，结果流出 Flink 但实际上并未保留在 Flink 中。