本文主要是介绍Flink实例(115):自定义时间和窗口的操作符(十四)窗口操作符(四)触发器(Triggers) (二),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
Flink 中窗口是很重要的一个功能,而窗口又经常配合触发器一起使用。
Flink 自带的触发器大概有:
CountTrigger: 指定条数触发ContinuousEventTimeTrigger:指定事件时间触发
ContinuousProcessingTimeTrigger:指定处理时间触发ProcessingTimeTrigger: 默认触发器,窗口结束触发
EventTimeTrigger: 默认处理时间触发器,窗口结束触发NeverTrigger:全局窗口触发器,不触发
但是没有可以指定时间和条数一起作为触发条件的触发器,所有就自己实现了一个(参考:ProcessingTimeTrigger、CountTrigger)
看下调用触发器的窗口代码:
这篇关于Flink实例(115):自定义时间和窗口的操作符(十四)窗口操作符(四)触发器(Triggers) (二)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!