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

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

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



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

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

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