Interface SliceUnsharedAssigner
-
- All Superinterfaces:
Serializable
,SliceAssigner
,WindowAssigner
- All Known Implementing Classes:
SliceAssigners.SlicedUnsharedSliceAssigner
,SliceAssigners.TumblingSliceAssigner
,SliceAssigners.WindowedSliceAssigner
@Internal public interface SliceUnsharedAssigner extends SliceAssigner
ASliceAssigner
which doesn't share slices for windows, which means a window is divided into only one slice and doesn't need to merge the slices when emitting windows.Classical window of
SliceUnsharedAssigner
is tumbling window.
-
-
Method Summary
-
Methods inherited from interface org.apache.flink.table.runtime.operators.window.tvf.slicing.SliceAssigner
assignSliceEnd, expiredSlices, getLastWindowEnd, getSliceEndInterval, getWindowStart
-
Methods inherited from interface org.apache.flink.table.runtime.operators.window.tvf.common.WindowAssigner
getDescription, isEventTime
-
-