本文共 196 字,大约阅读时间需要 1 分钟。
Flink的Window API采用松耦合设计,能够灵活定义符合特定业务需求的窗口。
在Flink中定义窗口主要需要以下三个关键组件:窗口分配器、触发器和驱逐者。
在触发器触发后,驱逐者(Evictor)会在窗口处理之前剔除不需要的元素,类似于过滤器。驱逐者可以翻译为“驱逐者”,其功能是移除窗口中不必要的元素。
驱逐者剔除元素的时机是在触发器触发时。
转载地址:http://inik.baihongyu.com/