窗口原理与机制 图片链接：https://blog.csdn.net/qq_35590459/article/details/132177154 数据流进入算子前，被提交给WindowAssigner，决定元素被放到哪个或哪些窗口，同时可能会创建新窗口或者合并旧的窗口。 每一个窗口都拥有一个属于自己的触发器Trigger，每当有元素被分配到该窗口，或者之前注册的定时器超时时，Trigger都会被调用。 Trigger被触发后，窗口中的元素集合就会交给Evictor（如果指定了），遍历窗口中的元素列表，并决定最先进入窗口的多少个元素需要被移除。 窗口函数计算结果值，发送给下游； Trigger 触发器 触发器作用：控制窗口什么时候除法计算。即执行窗口函数；基于WindowStream调用trigger（）方法，传入自定义触发器（trigger）； 每一个窗口分配器（windowAssigner） 都会对应一个默认的触发器； 源码样例 @PublicEvolving public <W extends Window> WindowedStream<T, KEY, W> window(...
