Uses of Interface
org.apache.flink.table.runtime.operators.window.MergeCallback
-
-
Uses of MergeCallback in org.apache.flink.table.runtime.operators.aggregate.window.processors
Classes in org.apache.flink.table.runtime.operators.aggregate.window.processors that implement MergeCallback Modifier and Type Class Description classSliceSharedWindowAggProcessorAn window aggregate processor implementation which works forSliceSharedAssigner, e.g. -
Uses of MergeCallback in org.apache.flink.table.runtime.operators.window.groupwindow.assigners
Methods in org.apache.flink.table.runtime.operators.window.groupwindow.assigners with parameters of type MergeCallback Modifier and Type Method Description abstract voidMergingWindowAssigner. mergeWindows(W newWindow, NavigableSet<W> sortedWindows, MergeCallback<W,Collection<W>> callback)Determines which windows (if any) should be merged.voidSessionWindowAssigner. mergeWindows(TimeWindow newWindow, NavigableSet<TimeWindow> sortedWindows, MergeCallback<TimeWindow,Collection<TimeWindow>> callback) -
Uses of MergeCallback 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 MergeCallback Modifier and Type Method Description voidSliceAssigners.CumulativeSliceAssigner. mergeSlices(long sliceEnd, MergeCallback<Long,Iterable<Long>> callback)voidSliceAssigners.HoppingSliceAssigner. mergeSlices(long sliceEnd, MergeCallback<Long,Iterable<Long>> callback)voidSliceAssigners.SlicedSharedSliceAssigner. mergeSlices(long sliceEnd, MergeCallback<Long,Iterable<Long>> callback)voidSliceSharedAssigner. mergeSlices(long sliceEnd, MergeCallback<Long,Iterable<Long>> callback)Determines which slices (if any) should be merged. -
Uses of MergeCallback in org.apache.flink.table.runtime.operators.window.tvf.unslicing
Methods in org.apache.flink.table.runtime.operators.window.tvf.unslicing with parameters of type MergeCallback Modifier and Type Method Description voidUnsliceAssigners.WindowedUnsliceAssigner. mergeWindows(TimeWindow newWindow, NavigableSet<TimeWindow> sortedWindows, MergeCallback<TimeWindow,Collection<TimeWindow>> callback)
-