相同點:
1 均是對相同類型的元素進行合并
2 均是把組内的所有元素合并成一個值
不同點:
1 reduce是組内的2個元素合并成一個同類型的新元素;fold是組内的每個元素與累加器(一開始是初始值initialValue)合并再傳回累加器,累加器的類型可以與組内的元素類型不一緻;
2 reduce可以用于DataStream或DataSet,但是fold隻能用于DataStream。
Flink reduce 作用 執行個體
Flink fold算子 執行個體 (所有訂單的分類彙總資訊)
以下是源碼,flink1.9.2,注意看注釋: