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);
}
}