scala - flink 表 SQL 接口

Question

我想知道我们是否可以在 flink Table 和 SQL api 中使用两个表（join）来编写查询。

我是 flik 的新手，我想从两个不同的数据集创建两个表并查询它们并生成其他数据集。

我的查询是这样的select... from table1, table 2...，我们可以像这样查询两个或更多表的查询吗？

谢谢

Answer 1

Flink 的 Table API 支持对批处理表（例如从 a 创建的那些）进行连接操作（全连接、左连接、右连接、内连接DataSet）。

SELECT c, g FROM Table3, Table5 WHERE b = e

对于流式表（例如从 a 创建的表DataStream），Flink 尚不支持连接操作。但 Flink 社区正在积极努力在不久的将来添加它们。