自定义trigger  继承 抽象类 Trigger<T, TimeWindow>   

主要实现 Trigger类的四个方法（onElement、onEventTime、onProcessingTime、clear），在重写方法中 返回触发的结果TriggerResult.FIRE_AND_PURGE还是TriggerResult.CONTINUE

标签：触发,自定义,Flink,PURGE,计数,Trigger,onProcessingTime,TriggerResult
来源： https://www.cnblogs.com/gouhaiping/p/15634313.html