Uses of Interface
org.apache.flink.table.runtime.operators.window.async.tvf.slicing.AsyncStateSlicingWindowProcessor
-
Packages that use AsyncStateSlicingWindowProcessor Package Description org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors -
-
Uses of AsyncStateSlicingWindowProcessor in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors
Classes in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors that implement AsyncStateSlicingWindowProcessor Modifier and Type Class Description classAbstractAsyncStateSliceWindowAggProcessorA base implementation ofAsyncStateSlicingWindowProcessorfor window aggregate.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.
-