scala - 在 Java/Scala 程序中从 DataStream 创建 SQL 表并从 SQL 客户端 CLI 查询它 - Apache Flink

Question

是否可以使用 Flink SQL 客户端 CLI 与表交互，其中哪个表是在集群中运行的 Scala/Java 程序中创建的？

Answer 1

不，这是不可能的。

您可以将 Scala/Java 程序的 DataStream 放入消息队列或事件日志（如 Apache Kafka 或 Apache Pulsar）中的主题中，并将该主题注册为 CLI 客户端中的表。

一旦表被注册，就可以在客户端使用 SQL 进行查询。