1.4 ApacheのFLINK上foldLeft事業者と同等の は、ウィンドウ が、その後</p>が <p>集約演算の出力は集合体であるkeyBy私は、その後でDataStream と、この使用してApache FLINK 1.4 開始のようなストリームを設定しているでDataStream

Question

ありますAggregateResultオブジェクト 今終了するストリームはSingleOutputStreamOperator型です

私が次に望むのは、scala foldLeftと同じです。その機能を提供する演算子がありますか？

おかげ

Answer 1

FLINK 1.4 foldLeftに似ていることAggregateFunctionを提供します。

API of the AggregateFunctionは次のように機能します。最初の（または開始）値はcreateAccumulator()メソッドで定義されています。アキュムレータは、部分的に集計された値を保持します。値は、add()メソッドを使用してアキュムレータに集計されます。最後に、結果は、getResult()メソッドによるアキュムレータから計算されます。

foldLeftとの違いは、AggregateFunctionがそのアキュムレータ（部分集合体）をmerge()メソッドでマージできることです。一部のウィンドウタイプ（セッションウィンドウ）には部分集約をマージする機能が必要であり、特定の最適化に役立ちます。