Flink 同时按照计数和时间触发窗口计算
自定义trigger 继承 抽象类 Trigger
主要实现 Trigger类的四个方法(onElement、onEventTime、onProcessingTime、clear),在重写方法中 返回触发的结果TriggerResult.FIRE_AND_PURGE还是TriggerResult.CONTINUE
自定义trigger 继承 抽象类 Trigger
主要实现 Trigger类的四个方法(onElement、onEventTime、onProcessingTime、clear),在重写方法中 返回触发的结果TriggerResult.FIRE_AND_PURGE还是TriggerResult.CONTINUE