Uses of Class
org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors.AbstractAsyncStateWindowAggProcessor
-
Packages that use AbstractAsyncStateWindowAggProcessor Package Description org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors -
-
Uses of AbstractAsyncStateWindowAggProcessor in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors
Subclasses of AbstractAsyncStateWindowAggProcessor in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors 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.
-