flink1.12.x Transformation-union() 和 connect() 的区别

区别

  • connect 只能连接两个数据流,union 可以连接多个数据流。

  • connect 所连接的两个数据流的 数据类型可以不一致
    union 所连接的两个数据流的 数据类型必须一致

  • 两个 DataStream 经过 connect 之后被转化为ConnectedStreams,ConnectedStreams 会对两个流的数据应用 不同的处理方法,且双流之间可以共享状态。

  • connect 应用在:对一个数据流,使用另外一个流,进行控制处理。控制流可以是阈值、规则、机器学习模型或其他参数。


原文出处:/show_1IX444ogCv91.html