Flink 自定义触发器

  trigger接口有五个方法容许trigger对不一样的事件作出反应：ide onElement():进入窗口的每一个元素都会调用该方法。大数据 onEventTime():事件时间timer触发的时候被调用。this onProcessingTime():处理时间timer触发的时候会被调用。对象 onMerge():有状态的触发器相关，并在它们相应的窗口合并时合并两个触发器的状态，例如使用

>>阅读原文<<