Package org.apache.flink.table.runtime.operators.aggregate.window.processors
-
Class Summary Class Description AbstractSliceWindowAggProcessor A base implementation ofSlicingWindowProcessorfor window aggregate.AbstractWindowAggProcessor<W> A base class for window aggregate processors.SliceSharedWindowAggProcessor An window aggregate processor implementation which works forSliceSharedAssigner, e.g.SliceUnsharedWindowAggProcessor An window aggregate processor implementation which works forSliceUnsharedAssigner, e.g.UnsliceWindowAggProcessor An window aggregate processor implementation which works forUnsliceAssigner, e.g.