自定义trigger 继承 抽象类 Trigger<T, TimeWindow>
主要实现 Trigger类的四个方法（onElement、onEventTime、onProcessingTime、clear），
在onElement()方法中实现计数逻辑 。
在onEventTime()方法中实现计时逻辑
在前三个重写方法中 通过返回触发的结果TriggerResult.FIRE还是TriggerResult.CONTINUE来决定是否触发窗口计算
自定义trigger 继承 抽象类 Trigger<T, TimeWindow>
主要实现 Trigger类的四个方法（onElement、onEventTime、onProcessingTime、clear），
在onElement()方法中实现计数逻辑 。
在onEventTime()方法中实现计时逻辑
在前三个重写方法中 通过返回触发的结果TriggerResult.FIRE还是TriggerResult.CONTINUE来决定是否触发窗口计算
《Flink 同时按照计数和时间触发窗口计算.doc》
下载本文的Word格式文档，以方便收藏与打印。
