@Internal public interface UnslicingWindowProcessor<W> extends WindowProcessor<W>
UnslicingWindowProcessor
is an optimized processing for unaligned windows.
A UnslicingWindowProcessor
usually leverages the UnsliceAssigner
to assign
slices and calculate based on the window.
Note: Currently, the UnslicingWindowProcessor
only support session time window.
See more details in WindowAggOperator
.
WindowProcessor.Context<W>
advanceProgress, clearWindow, close, createWindowSerializer, fireWindow, initializeWatermark, open, prepareCheckpoint, processElement
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.