Flink DataStream Evictors(驱逐器)_flink 驱逐器使用样例-CSDN博客

网站介绍:文章浏览阅读1.4k次。Flink DataStream Evictors(驱逐器)Flink 窗口模式允许特别的算子Evictor(驱逐器),应用在WindowAssigner和trigger之间。通过evictor()方法使用。Evictor驱逐器能够在element进入Window窗口聚合之前进行移除数据或者在进入Window窗口聚合后,Trigger触发计算操作之前移除数据。Evictor的2个方法:..._flink 驱逐器使用样例