哭泣老鼠

文章
1
资源
0
加入时间
4年4月11天

Flink - 13.CountAndProcessingTimeTrigger 基于 Count 和 Time 触发窗口

​上一篇文章提到了CountTrigger && ProcessingTimeTriger,前者 CountTrigger 指定 count 数,当窗口内元素满足逻辑时进行一次触发,后者通过 TimeServer 注册窗口过期时间,到期后进行一次触发,本文自定义 Trigger 实现二者的合并即 Count 和 ProcessingTime 满足任意条件窗口都进行一次触发。...