You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by smq <37...@qq.com> on 2021/03/08 07:33:39 UTC

回复:自定义窗口触发器 Trigger

补充一下,我是继承Trigger自己实现了一个定时器,然后只重写了三个抽象方法





------------------ 原始邮件 ------------------
发件人: smq <374060171@qq.com&gt;
发送时间: 2021年3月8日 15:30
收件人: user-zh <user-zh@flink.apache.org&gt;
主题: 回复:自定义窗口触发器 Trigger



Trigger 抽象类其中有两个方法,onProcessingTime ()和OnEventTime (),在源码描述中,当trigger context设置的定时器触发时会调用上面两个方法。但是在实际测试中,发现,就算没有设置定时器,上面的方法也能在水印超过窗口最大时间之后触发。请问有人知道了解过这个吗。