Flink DataStreamunionconnect都有一个共同的作用,就是将2个流或多个流合成一个流。但是两者的区别是:union连接的2个流的类型必须一致,connect连接的流可以不一致,但是可以统一处理。

具体看下面示例:

1
2
3
public class ConnectOperator {

}

connect可以将2个不同类型的流同时用不同的逻辑处理好,形成一个流。

union是将2个同类型的流,合成一个,进行处理。