2017-06-02 67 views
0

我想知道我们可以使用flink Table和SQL api中的两个表(连接)来编写查询。flink Table SQL Api

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

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

感谢

回答

2

弗林克的表API支持加入批次表操作(全,左,右,内部连接)(例如那些从DataSet创建)。

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

对于流表(例如那些从DataStream创建),弗林克还不支持连接操作。但Flink社区正在积极努力在不久的将来添加它们。