Uses of Interface
org.apache.flink.table.runtime.operators.window.async.AsyncMergeCallback

Packages that use AsyncMergeCallback

Package	Description
org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors
org.apache.flink.table.runtime.operators.window.tvf.slicing

Uses of AsyncMergeCallback in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors

Classes in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors that implement AsyncMergeCallback

Modifier and Type	Class	Description
class	AsyncStateSliceSharedWindowAggProcessor	A window aggregate processor implementation which works for SliceSharedAssigner with async state api, e.g. hopping windows and cumulative windows.

Uses of AsyncMergeCallback in org.apache.flink.table.runtime.operators.window.tvf.slicing

Methods in org.apache.flink.table.runtime.operators.window.tvf.slicing with parameters of type AsyncMergeCallback

Modifier and Type	Method	Description
org.apache.flink.api.common.state.v2.StateFuture<org.apache.flink.api.java.tuple.Tuple2<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>>	SliceAssigners.CumulativeSliceAssigner.asyncMergeSlices(long sliceEnd, AsyncMergeCallback<Long,Iterable<Long>> callback)
org.apache.flink.api.common.state.v2.StateFuture<org.apache.flink.api.java.tuple.Tuple2<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>>	SliceAssigners.HoppingSliceAssigner.asyncMergeSlices(long sliceEnd, AsyncMergeCallback<Long,Iterable<Long>> callback)
org.apache.flink.api.common.state.v2.StateFuture<org.apache.flink.api.java.tuple.Tuple2<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>>	SliceAssigners.SlicedSharedSliceAssigner.asyncMergeSlices(long sliceEnd, AsyncMergeCallback<Long,Iterable<Long>> callback)
org.apache.flink.api.common.state.v2.StateFuture<org.apache.flink.api.java.tuple.Tuple2<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>>	SliceSharedAssigner.asyncMergeSlices(long sliceEnd, AsyncMergeCallback<Long,Iterable<Long>> callback)	Determines which slices (if any) should be merged and then merge them.