双数据流转换为单数据流操作的运算:cogroup, join和coflatmap

  • Join:只输出条件匹配的元素对。
  • CoGroup: 除了输出匹配的元素对以外,未能匹配的元素也会输出。
  • CoFlatMap:没有匹配条件,不进行匹配,分别处理两个流的元素。

 

CoFlatMap

stream1数据到来时,会调用flatMap1方法,stream2收到数据之时,会调用flatMap2方法

Flink系列:双数据流转换为单数据流

相关文章:

  • 2021-07-03
  • 2021-10-03
  • 2021-06-04
  • 2022-02-19
  • 2021-11-26
  • 2022-12-23
  • 2021-11-29
  • 2022-12-23
猜你喜欢
  • 2022-12-23
  • 2022-12-23
  • 2022-01-07
  • 2022-12-23
  • 2022-12-23
  • 2021-06-14
  • 2021-08-30
相关资源
相似解决方案