2017-06-02 70 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社區正在積極努力在不久的將來添加它們。