触发器原型中包括四类触发机制,基于事件驱动

Flink触发器概念

分别是:

(1)onElement:窗口每收到一个元素调用该方法,返回结果决定是否触发算子

Flink触发器概念

(2)onProcessingTime :根据注册的处理时间定时器触发

Flink触发器概念

(3)onEventTime:根据注册的事件事件触发

Flink触发器概念

(4)onMerge:窗口合并时触发

Flink触发器概念

 

 

 

 

 

 

相关文章: