相同点:

1 均是对相同类型的元素进行合并

2 均是把组内的所有元素合并成一个值

不同点:

1 reduce是组内的2个元素合并成一个同类型的新元素;fold是组内的每个元素与累加器(一开始是初始值initialValue)合并再返回累加器,累加器的类型可以与组内的元素类型不一致;

2 reduce可以用于DataStream或DataSet,但是fold只能用于DataStream。

Flink reduce 作用 实例

Flink fold算子 实例 (所有订单的分类汇总信息)

以下是源码,flink1.9.2,注意看注释:

Flink reduce与fold 相同点和不同点(区别)

 

Flink reduce与fold 相同点和不同点(区别)

 

Flink reduce与fold 相同点和不同点(区别)Flink reduce与fold 相同点和不同点(区别)

 

相关文章:

  • 2021-10-26
  • 2021-12-15
  • 2021-10-01
  • 2018-06-15
  • 2021-10-29
  • 2021-03-26
  • 2021-10-02
  • 2021-11-29
猜你喜欢
  • 2021-11-14
  • 2018-12-07
  • 2019-12-01
  • 2018-03-28
  • 2021-08-30
  • 2021-09-30
  • 2021-11-02
  • 2021-11-29
相关资源
相似解决方案