Flink雙流操做

簡介 Flink 雙數據流轉換爲單數據流操做的運算有cogroup, join和coflatmap。下面爲你們對比介紹下這3個運算的功能和用法。java Join：只輸出條件匹配的元素對。 CoGroup: 除了輸出匹配的元素對之外，未能匹配的元素也會輸出。 CoFlatMap：沒有匹配條件，不進行匹配，分別處理兩個流的元素。在此基礎上徹底能夠實現join和cogroup的功能，比他們使用上更加自

>>阅读原文<<