本文主要是介绍Flink reduce与fold 相同点和不同点(区别),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
相同点:
1 均是对相同类型的元素进行合并
2 均是把组内的所有元素合并成一个值
不同点:
1 reduce是组内的2个元素合并成一个同类型的新元素;fold是组内的每个元素与累加器(一开始是初始值initialValue)合并再返回累加器,累加器的类型可以与组内的元素类型不一致;
2 reduce可以用于DataStream或DataSet,但是fold只能用于DataStream。
Flink reduce 作用 实例
Flink fold算子 实例 (所有订单的分类汇总信息)
以下是源码,flink1.9.2,注意看注释:
这篇关于Flink reduce与fold 相同点和不同点(区别)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!