Uses of Interface
org.apache.flink.table.runtime.operators.window.tvf.common.SyncStateWindowProcessor
-
-
Uses of SyncStateWindowProcessor in org.apache.flink.table.runtime.operators.aggregate.window.processors
Classes in org.apache.flink.table.runtime.operators.aggregate.window.processors that implement SyncStateWindowProcessor 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. -
Uses of SyncStateWindowProcessor in org.apache.flink.table.runtime.operators.deduplicate.window.processors
Classes in org.apache.flink.table.runtime.operators.deduplicate.window.processors that implement SyncStateWindowProcessor Modifier and Type Class Description classRowTimeSyncStateWindowDeduplicateProcessorA rowtime window deduplicate processor. -
Uses of SyncStateWindowProcessor in org.apache.flink.table.runtime.operators.rank.window.processors
Classes in org.apache.flink.table.runtime.operators.rank.window.processors that implement SyncStateWindowProcessor Modifier and Type Class Description classSyncStateWindowRankProcessorA rowtime window rank processor. -
Uses of SyncStateWindowProcessor in org.apache.flink.table.runtime.operators.window.tvf.common
Constructors in org.apache.flink.table.runtime.operators.window.tvf.common with parameters of type SyncStateWindowProcessor Constructor Description WindowAggOperator(SyncStateWindowProcessor<W> windowProcessor, boolean isEventTime) -
Uses of SyncStateWindowProcessor in org.apache.flink.table.runtime.operators.window.tvf.slicing
Subinterfaces of SyncStateWindowProcessor in org.apache.flink.table.runtime.operators.window.tvf.slicing Modifier and Type Interface Description interfaceSlicingSyncStateWindowProcessor<W>TheSlicingSyncStateWindowProcessoris an optimized processing for aligned windows which can apply the slicing optimization. -
Uses of SyncStateWindowProcessor in org.apache.flink.table.runtime.operators.window.tvf.unslicing
Subinterfaces of SyncStateWindowProcessor in org.apache.flink.table.runtime.operators.window.tvf.unslicing Modifier and Type Interface Description interfaceUnslicingSyncStateWindowProcessor<W>TheUnslicingSyncStateWindowProcessoris an optimized processing for unaligned windows.
-