Flink學習筆記 --- 理解ConnectedStream 與 Union

在DataStream上有一個union的轉換dataStream.union(otherStream1, otherStream2, ...),用來合併多個流,新的流會包含所有流中的數據。 union是一個限制,就是所有合併的流類型必須是一致的。ConnectedStream提供了和Union類似的功能,也涌來連接兩個流,但是與union轉換有以下區別: 1.ConnectedStreamed只
相關文章
相關標籤/搜索