Search code examples
apache-flinkcomplex-event-processing

How does AggregateFunction impact State Size in Flink?


In Flink, if we apply a FoldFunction or an ReduceFunction on a window, it

eagerly aggregate elements and store only one value per window

See Flink Docs 1.3 for details.

Does the same hold true for an AggregateFunction - because it too seems to allow you to eagerly aggregate elements and store them.


Solution

  • Yes, an AggregateFunction stores a single accumulator per window.