对 左流 处理的逻辑 @param value @return @throws Exception

对 右流 处理的逻辑 @param value @return @throws Exception

批计算模式下，可能需要将多个上游的局部聚合累加器，放在下游进行全局聚合 因为需要对两个累加器进行合并 这里就是合并的逻辑 流计算模式下，不用实现！ @param a An accumulator to merge @param b Another accumulator to merge @r

来一条数据时，需要检查watermark是否已经越过窗口结束点需要触发

当事件时间定时器的触发时间（窗口的结束点时间）到达了，检查是否满足触发条件 下面的方法，是定时器在调用

当处理时间定时器的触发时间（窗口的结束点时间）到达了，检查是否满足触发条件

定期器被触发时，会调用的方法

This method is called immediately before any elements are processed, it should contain the operator's initialization logic, e.g. state initialization.