Flink-SingleOutputStreamOperator用法
Contents
Flink DataStream中union和connect都有一个共同的作用,就是将2个流或多个流合成一个流。但是两者的区别是:union连接的2个流的类型必须一致,connect连接的流可以不一致,但是可以统一处理。
具体看下面示例:
1 | public class ConnectOperator { |
connect可以将2个不同类型的流同时用不同的逻辑处理好,形成一个流。
union是将2个同类型的流,合成一个,进行处理。