Flink Operator之CoGroup、Join以及Connect

在Flink中由不少Operator,大體分爲兩類,DataStream和DataSet(還有高層的Table&SQL API),即流處理數據和批處理數據,這篇文章主要講解CoGroup、Join和Connect的使用,之因此將它們放在一塊兒是由於它們比較類似,但也有所不一樣,在DataStream和DataSet中都存在CoGroup、Join這兩個Operator,而Connect只適用於處理
相關文章
相關標籤/搜索