Flink系列:雙數據流轉換爲單數據流

    雙數據流轉換爲單數據流操作的運算:cogroup, join和coflatmap Join:只輸出條件匹配的元素對。 CoGroup: 除了輸出匹配的元素對以外,未能匹配的元素也會輸出。 CoFlatMap:沒有匹配條件,不進行匹配,分別處理兩個流的元素。   CoFlatMap stream1數據到來時,會調用flatMap1方法,stream2收到數據之時,會調用flatMap2方法
相關文章
相關標籤/搜索