flink evictors 和急切的窗口函数答案

【问题标题】：flink evictors and eager window functionsflink evictors 和急切的窗口函数
【发布时间】：2019-05-06 12:16:22
【问题描述】：

我对 flink evictor 和热切评估的窗口函数（例如 AggregateFunction 和 ReduceFunction）之间的关系感到困惑，

驱逐者可以在触发器触发后以及在应用窗口函数之前和/或之后从窗口中移除元素

听起来驱逐者并不急切，那么使用带有AggregateFunction 的驱逐者的行为是什么？是否有某个时刻将所有元素都分配到 RAM 的窗口中？

谢谢

【问题讨论】：

【解决方案1】：

注意指定一个驱逐者可以防止任何预聚合，因为在应用计算之前必须将窗口的所有元素传递给驱逐者。

我错过了这行 flink 。

【讨论】：