我对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的窗口中分配所有元素?
谢谢
注意驱逐器的注意力可防止任何预处理,因为在应用计算之前,必须将窗口的所有元素传递给驱动器。
我错过了这条弗林克。