flink自定义trigger详解
[1]中有句话是这样的:"其实,我们要实现基于事件时间的窗口随意输出,比如1000个元素触发一次输出,那么我们就可以通过修改这个触发器来实现。"这句话的意思是,默认的自带的trigger一般是基于EventTime的。那么这1000 个元素可能跨度是一小时,也可能跨度是两小时,对吧但是显然默认的Trigger只能是盯着EventTime(时间戳)来决定是否触发计算,并不能根据元素个数进行触发。也就是说,默认的Trigger盯着的跨度是"时间差"。而不是&q