public Processor get()

in core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java [60:71]


    public Processor<V> get() {
        WindowInfo.WindowType windowType = windowInfo.getWindowType();
        switch (windowType) {
            case SLIDING_WINDOW:
            case TUMBLING_WINDOW:
                return new WindowAccumulatorProcessor(name, windowInfo, selectAction, accumulator);
            case SESSION_WINDOW:
                return new SessionWindowAccumulatorProcessor(name, windowInfo, selectAction, accumulator);
            default:
                throw new RuntimeException("window type is error, WindowType=" + windowType);
        }
    }