Re: WindowedStream aggregation methods pre-aggregate?

Hi Elias, yes, reduce, fold, and the aggregation functions (sum, min, max, minBy, maxBy) on WindowedStream preform eager aggregation, i.e., the functions are apply for each value that enters the window and the state of the window will consist of a single value. In case you need access to the

WindowedStream aggregation methods pre-aggregate?

Can someone confirm whether the org.apache.flink.streaming.api.scala.WindowedStream methods other than "apply" (e.g. "sum") perform pre-aggregation? The API docs are silent on this.