public void removeOldAccumulatorSession()

in core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java [125:135]

• 10 lines of code
• 4 McCabe index (conditional complexity)

    public void removeOldAccumulatorSession(WindowKey oldWindowKey) {
        if (oldWindowKey == null) {
            return;
        }

        TimeType timeType = this.lastUpdateTime2WindowKey.get(oldWindowKey);
        if (timeType != null && timeType.getType() == Type.AccumulatorSessionWindow) {
            this.lastUpdateTime2WindowKey.remove(oldWindowKey);
        }
        this.fireSessionWindowCallback.remove(oldWindowKey);
    }