Uses of Class
org.apache.flink.table.runtime.operators.aggregate.window.processors.WindowAggProcessorBase
-
-
Uses of WindowAggProcessorBase in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors
Subclasses of WindowAggProcessorBase in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors Modifier and Type Class Description classAbstractAsyncStateSliceWindowAggProcessorA base implementation ofAsyncStateSlicingWindowProcessorfor window aggregate.classAbstractAsyncStateWindowAggProcessor<W>A base class for window aggregate processors with async state.classAsyncStateSliceSharedWindowAggProcessorA window aggregate processor implementation which works forSliceSharedAssignerwith async state api, e.g. hopping windows and cumulative windows.classAsyncStateSliceUnsharedWindowAggProcessorA window aggregate processor implementation which works forSliceUnsharedAssignerwith async state, e.g. tumbling windows. -
Uses of WindowAggProcessorBase in org.apache.flink.table.runtime.operators.aggregate.window.processors
Subclasses of WindowAggProcessorBase in org.apache.flink.table.runtime.operators.aggregate.window.processors Modifier and Type Class Description classAbstractSliceSyncStateWindowAggProcessorA base implementation ofSlicingSyncStateWindowProcessorfor window aggregate.classAbstractSyncStateWindowAggProcessor<W>A base class for window aggregate processors.classSliceSharedSyncStateWindowAggProcessorA window aggregate processor implementation which works forSliceSharedAssigner, e.g.classSliceUnsharedSyncStateWindowAggProcessorA window aggregate processor implementation which works forSliceUnsharedAssigner, e.g.classUnsliceSyncStateWindowAggProcessorAn window aggregate processor implementation which works forUnsliceAssigner, e.g.
-