在flink中，如果我们在窗口上应用foldfunction或reducefunction，它
急切地聚合元素，每个窗口只存储一个值
详见flink docs 1.3。
aggregatefunction也是如此，因为它似乎也允许您急切地聚合元素并存储它们。