Uses of Interface
org.apache.flink.table.runtime.operators.window.tvf.common.WindowProcessor
-
-
Uses of WindowProcessor in org.apache.flink.table.runtime.operators.aggregate.window.processors
Classes in org.apache.flink.table.runtime.operators.aggregate.window.processors that implement WindowProcessor Modifier and Type Class Description classAbstractSliceWindowAggProcessorA base implementation ofSlicingWindowProcessorfor window aggregate.classAbstractWindowAggProcessor<W>A base class for window aggregate processors.classSliceSharedWindowAggProcessorAn window aggregate processor implementation which works forSliceSharedAssigner, e.g.classSliceUnsharedWindowAggProcessorAn window aggregate processor implementation which works forSliceUnsharedAssigner, e.g.classUnsliceWindowAggProcessorAn window aggregate processor implementation which works forUnsliceAssigner, e.g. -
Uses of WindowProcessor in org.apache.flink.table.runtime.operators.deduplicate.window.processors
Classes in org.apache.flink.table.runtime.operators.deduplicate.window.processors that implement WindowProcessor Modifier and Type Class Description classRowTimeWindowDeduplicateProcessorA rowtime window deduplicate processor. -
Uses of WindowProcessor in org.apache.flink.table.runtime.operators.rank.window.processors
Classes in org.apache.flink.table.runtime.operators.rank.window.processors that implement WindowProcessor Modifier and Type Class Description classWindowRankProcessorA rowtime window rank processor. -
Uses of WindowProcessor 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 WindowProcessor Constructor Description WindowAggOperator(WindowProcessor<W> windowProcessor, boolean isEventTime) -
Uses of WindowProcessor in org.apache.flink.table.runtime.operators.window.tvf.slicing
Subinterfaces of WindowProcessor in org.apache.flink.table.runtime.operators.window.tvf.slicing Modifier and Type Interface Description interfaceSlicingWindowProcessor<W>TheSlicingWindowProcessoris an optimized processing for aligned windows which can apply the slicing optimization. -
Uses of WindowProcessor in org.apache.flink.table.runtime.operators.window.tvf.unslicing
Subinterfaces of WindowProcessor in org.apache.flink.table.runtime.operators.window.tvf.unslicing Modifier and Type Interface Description interfaceUnslicingWindowProcessor<W>TheUnslicingWindowProcessoris an optimized processing for unaligned windows.
-