Flink自定义Trigger
1. 介绍本文主要介绍开窗后自定义窗口触发器，触发器触发包括两部分：1.当窗口内的数据量达到一定数量后触发2.当事件事件达到窗口最大时间戳后触发2. 环境Flink: 1.13.1java:1.8.251scala:2.11.123.Trigger类中主要方法1）onElement() 为添加到窗格中的每个元素调用。此方法的结果将决定是否对窗格进行触发。2）onProcessingTime() Flink使用的是处理时间语义时使用，该方法用来以时间作为条件触发窗口。3）onEv
