core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java [46:57]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                                        StreamContext<V> context,
                                        MessageQueue stateTopicMessageQueue,
                                        BiFunction<Long, MessageQueue, Long> commitWatermark) {
        super(context, stateTopicMessageQueue, commitWatermark);
        this.windowStore = windowStore;
    }

    public List<WindowKey> fire(String operatorName, long watermark) {
        List<WindowKey> fired = new ArrayList<>();

        try {
            List<Pair<WindowKey, WindowState<K, Accumulator<R, OV>>>> pairs = windowStore.searchLessThanWatermark(operatorName, watermark);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorWindowFire.java [44:56]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                                 StreamContext<V> context,
                                 MessageQueue stateTopicMessageQueue,
                                 BiFunction<Long, MessageQueue, Long> commitWatermark) {
        super(context, stateTopicMessageQueue, commitWatermark);
        this.windowStore = windowStore;
    }


    public List<WindowKey> fire(String operatorName, long watermark) {
        List<WindowKey> fired = new ArrayList<>();

        try {
            List<Pair<WindowKey, WindowState<K, Accumulator<R, OV>>>> pairs = windowStore.searchLessThanWatermark(operatorName, watermark);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -