粗暴钥匙

文章
7
资源
0
加入时间
3年0月21天

【4.1】flink窗口算子的trigger触发器和Evictor清理器【README】【1】触发器trigger【2】清理器 evictor 【3】滑动计数窗口代码【4】 滑动计数窗口代码变体【小结】

【README】本文记录了 窗口算子的触发器trigger和 evictor清理器;trigger触发器:决定了一个窗口(由 window assigner 定义)何时可以被 window function 处理; evictor清理器: evictor 可以在 trigger 触发后、调用窗口函数之前或之后从窗口中删除元素;【1】触发器trigger1)Trigger 接口提供了五个方法来响应不同的事件:onElement() 方法在每个元素被加入窗口时调用。 onEventTime