FLINK 1.9.1 TriggerResult.FIRE_AND_PURGE 与 ctx.registerEventTimeTimer()

[CHENJIE]

大家新年快乐！


版本：FLINK 1.9.1


----部分代码
.keyBy("key")
.window(EventTimeSessionWindows.withGap(Time.hours(1)))
.trigger(new NewTrigger())
.process(new NewProcess())


--NewTrigger()
@Override
public TriggerResult onElement(Bean bean, long l, TimeWindow timeWindow, TriggerContext ctx) throws Exception {
..
ctx.registerEventTimeTimer(l + INTERVAL);
return TriggerResult.FIRE_AND_PURGE;
}


问题：
通过触发器，定义在窗口内，每隔固定时间计算一次并且清空计算数据，正常如果固定时间内没有数据也要输出一次。
但是实际用的时候只有窗口有数据的时候才会触发process计算，如果没有数据不会触发，TriggerResult.FIRE_AND_PURGE改为TriggerResult.FIRE之后就可以正常的固定每隔一定时间输出一次。
TriggerResult.FIRE_AND_PURGE会有哪些操作？好像不止清理了窗口数据，还对触发时间有操作呀？

[CHENJIE]

看到源码了，这里如果contents == null，就不触发计算了
evictingWindowState.clear();会导致contents 变成null，然后如果窗口没有数据就不会触发窗口计算




if (triggerResult.isFire()) {
   Iterable<StreamRecord<IN>> contents = evictingWindowState.get();
if (contents == null) {
// if we have no state, there is nothing to do
continue;
   }
   emitWindowContents(actualWindow, contents, evictingWindowState);
}
-- 这里会吧 evictingWindowState给clear了
if (triggerResult.isPurge()) {
evictingWindowState.clear();
}








在 2020-01-19 13:27:17，"USERNAME" <[hidden email]> 写道：

>大家新年快乐！
>
>
>版本：FLINK 1.9.1
>
>
>----部分代码
>.keyBy("key")
>.window(EventTimeSessionWindows.withGap(Time.hours(1)))
>.trigger(new NewTrigger())
>.process(new NewProcess())
>
>
>--NewTrigger()
>@Override
>public TriggerResult onElement(Bean bean, long l, TimeWindow timeWindow, TriggerContext ctx) throws Exception {
>..
>ctx.registerEventTimeTimer(l + INTERVAL);
>return TriggerResult.FIRE_AND_PURGE;
>}
>
>
>问题：
>通过触发器，定义在窗口内，每隔固定时间计算一次并且清空计算数据，正常如果固定时间内没有数据也要输出一次。
>但是实际用的时候只有窗口有数据的时候才会触发process计算，如果没有数据不会触发，TriggerResult.FIRE_AND_PURGE改为TriggerResult.FIRE之后就可以正常的固定每隔一定时间输出一次。
>TriggerResult.FIRE_AND_PURGE会有哪些操作？好像不止清理了窗口数据，还对触发时间有操作呀？
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>