Package org.apache.flink.table.runtime.operators.aggregate.window.processors
-
Class Summary Class Description AbstractSliceWindowAggProcessor A base implementation ofSlicingWindowProcessor
for 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.