AggregateFunction 如何影响 Flink 中的 State Size？

Question

在 Flink 中，如果我们在 window 上应用 FoldFunction 或 ReduceFunction，它

eagerly aggregate elements and store only one value per window

详情见Flink Docs 1.3。

对于 AggregateFunction 是否同样适用 - 因为它似乎也允许您热切地聚合元素并存储它们。

Answer 1

是的，AggregateFunction 每个 window 存储一个累加器。