3.3.7　union轉換

這個轉換執行兩個或多個數據流的合并。它對兩個或者兩個以上的DataStream流執行union操作，產生一個包含所有DataStream元素的新的DataStream流。關于union轉換的簡單介紹見表3-7。

表3-7　union轉換運算

在DataStream上使用union操作可以合并多個同類型的數據流，并生成同類型的數據流，即可將多個DataStream[T]合并為一個新的DataStream[T]。數據將按照先進先出（First In First Out）的模式合并，并且不去重。例如，執行union轉換操作對白色和深色兩個數據流進行合并，生成一個結果數據流，如圖3-6所示。

圖3-6　使用union轉換操作合并數據流

在下面的示例中演示了union轉換操作的用法。

Scala代碼如下：

Java代碼如下：

執行以上代碼，輸出結果如下：