天天看點

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 相同點和不同點(差別)
Flink reduce與fold 相同點和不同點(差別)
Flink reduce與fold 相同點和不同點(差別)
Flink reduce與fold 相同點和不同點(差別)

繼續閱讀