Uses of Interface
org.apache.flink.table.runtime.operators.window.async.tvf.common.AsyncStateWindowProcessor
-
-
Uses of AsyncStateWindowProcessor in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors
Classes in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors that implement AsyncStateWindowProcessor 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 AsyncStateWindowProcessor in org.apache.flink.table.runtime.operators.window.async.tvf.common
Constructors in org.apache.flink.table.runtime.operators.window.async.tvf.common with parameters of type AsyncStateWindowProcessor Constructor Description AsyncStateWindowAggOperator(AsyncStateWindowProcessor<W> windowProcessor, boolean isEventTime) -
Uses of AsyncStateWindowProcessor in org.apache.flink.table.runtime.operators.window.async.tvf.slicing
Subinterfaces of AsyncStateWindowProcessor in org.apache.flink.table.runtime.operators.window.async.tvf.slicing Modifier and Type Interface Description interfaceAsyncStateSlicingWindowProcessor<W>TheAsyncStateSlicingWindowProcessoris an optimized processing for aligned windows which can apply the slicing optimization.
-