Window Trigger
如果想让窗口每隔两分钟就触发一次结果输出呢?
PuringTrigger会对窗口里面的状态做一次清理 在第二次输出12:00 -12:05窗口结果的时候是3而不是6,这样可以保障下游的算子接收到的上游处理完成的结果后可以做累加产生正确的结果。

Window Trigger
如果想让窗口每隔两分钟就触发一次结果输出呢?
PuringTrigger会对窗口里面的状态做一次清理 在第二次输出12:00 -12:05窗口结果的时候是3而不是6,这样可以保障下游的算子接收到的上游处理完成的结果后可以做累加产生正确的结果。