×

scala

java 时间触发器实例_flink 自定义触发器 定时或达到数量触发

盖世火锅店 盖世火锅店 发表于2024-05-09 浏览5411 评论0
flink 触发器 触发器确定窗口(由窗口分配程序形成)何时准备由窗口函数处理。每个WindowAssigner都带有一个默认触发器。 如果默认触发器不适合需求,我们就需要自定义触发器。 主要方法 触发器接口有五种方法,允许触发器对不同的事件作出反应 onElement()添加到每个窗口的元素都会调用此方法。 onEventTime()当注册的事件时间计时器触发时,将调用此方法。 onProcessingTime()当注册的处理时间计时器触发时,将调用此方法。 onMerge