相同点:

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 相同点和不同点(区别)

 

相关文章:

  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2022-01-24
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2021-07-02
猜你喜欢
  • 2021-10-18
  • 2022-12-23
  • 2022-12-23
  • 2022-01-14
  • 2022-12-23
  • 2021-11-14
  • 2021-10-08
相关资源
相似解决方案