Flink的触发器Trigger介绍和使用

触发器定义了window什么时候会被求值以及什么时候发送求值结果。触发器能够到了特定的时间触发也能够碰到特定的事件触发。例如：观察到事件数量符合必定条件或者观察到了特定的事件。java 默认的触发器将会在两种状况下触发 处理时间：机器时间到达处理时间 事件时间：水位线超过了窗口的结束时间web 触发器能够访问流的时间属性以及定时器，还能够对state状态编程。因此触发器和process funct

>>阅读原文<<