Package org.apache.flink.table.runtime.operators.aggregate.window.processors

Class Summary

Class	Description
AbstractSliceSyncStateWindowAggProcessor	A base implementation of SlicingSyncStateWindowProcessor for window aggregate.
AbstractSyncStateWindowAggProcessor<W>	A base class for window aggregate processors.
SliceSharedSyncStateWindowAggProcessor	A window aggregate processor implementation which works for SliceSharedAssigner, e.g.
SliceUnsharedSyncStateWindowAggProcessor	A window aggregate processor implementation which works for SliceUnsharedAssigner, e.g.
UnsliceSyncStateWindowAggProcessor	An window aggregate processor implementation which works for UnsliceAssigner, e.g.
WindowAggProcessorBase<W,C extends WindowProcessor.Context<W>>