沉重 Table SQL Api

Question

我想知道我们可以在 flink Table 和 SQL api.

中使用两个 tables ( join) 来编写查询吗

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

我的查询会像 select... from table1, table 2... 那么我们可以这样写查询两个 table 或更多的查询吗？

谢谢

Answer 1

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

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

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