flink驱逐和急切的窗口功能



我对flink驱逐和热切评估的窗口功能(例如 AggregateFunction and ReduceFunction

(的关系感到困惑

来自flink doc:(https://ci.apache.org/projects/flink/flink/flink/flink-docs-stable/dev/dev/stream/poerators/windows.html#evictors(

驱动器具有触发触发后和/或应用窗口函数之前和/或之后从窗口中删除元素的能力

听起来像是驱逐器并不渴望,那么将驱逐器与AggregateFunction一起使用是什么行为?是否有时间在RAM的窗口中分配所有元素?

谢谢

注意驱逐器的注意力可防止任何预处理,因为在应用计算之前,必须将窗口的所有元素传递给驱动器。

我错过了这条弗林克。

最新更新