Flink union算法多流合并

在DataStream上使用union算子可以合并多个同类型的数据流，并生成同类型的数据流，即可以将多个DataStream[T]合并为一个新的DataStream[T]。数据将按照先进先出（First In First Out）的模式合并，且不去重。下图union对白色和深色两个数据流进行合并，生成一个数据流。

String[] lists = {"file1", "file2", "file3"};

        // 多个数据流进行整合；
        DataStream inputStream = null;

        for (String list : lists) {
            
            if (inputStream == null) {
                inputStream = env.readTextFile(list);
            }
            else {
                inputStream = inputStream.union(env.readTextFile(list));
            }
        }
inputStream.print();