Flink,union双流，union实例，java版本

二十六画生的博客

于 2020-06-17 12:29:44 发布

阅读量1.7k

点赞数

分类专栏： Flink 文章标签： Flink union 双流 java

本文链接：https://blog.csdn.net/u010002184/article/details/106804745

版权

Flink 专栏收录该内容

68 篇文章 ¥29.90 ¥99.00

订阅专栏

超级会员免费看

本文通过实例展示了Flink中union操作双流的过程，说明了union后生成的新流不会进行去重处理。在Flink版本1.9.2和Java 1.8环境下，分别从source1和source2每秒发送消息，union后直接打印，观察到重复的消息并未被过滤。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

union双流后会生成一个新的流，没有去重

package union;

import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.source.SourceFunction;
import org.apache.flink.streaming.api.functions.windowing.AllWindowFunction;
import org.apache.flink.streaming.api.windowing.time.Time;
import org.apache.flink.streaming.api.windowing.windows.TimeWindow;
import org.apache.flink.util.Collector;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.