Flink之Trigger
Flink是真正的实时处理,数据流入flink的source之后,假如需要窗口函数,我们就要使用一定的规则来判断或者叫决定该数据应该属于哪个窗口,然后是窗口要是基于事件时间的话我们还要提供时间戳抽取器和watermark分配器,最后还要指定满足何种条件触发窗口计算并输出结果。 那可能会说了触发窗口计算,不就是时间到窗口结束时间了直接输出不就行了吗?这样输出的频率可以直接由滑动间隔来控制了。 实际上,不行的,基于事件时间处理机制,数据会在有些意想不到的情况下滞后,比如forward故障等,