2

私は Apache Flink 1.4 を使用してこのようなストリーム設定をしています

集計操作の出力は AggregateResult オブジェクトであるため、現在終了するストリームは SingleOutputStreamOperator 型です。

次にやりたいことは、scala foldLeft に相当するものです。その機能を提供するオペレーターはありますか。

ありがとう

4

1 に答える 1