Class SliceAssigners.SlicedUnsharedSliceAssigner
- java.lang.Object
-
- org.apache.flink.table.runtime.operators.window.slicing.SliceAssigners.SlicedUnsharedSliceAssigner
-
- All Implemented Interfaces:
Serializable,SliceAssigner,SliceUnsharedAssigner
- Enclosing class:
- SliceAssigners
public static final class SliceAssigners.SlicedUnsharedSliceAssigner extends Object implements SliceUnsharedAssigner
TheSliceAssignerfor elements have been attached slice end timestamp, but the slices are not shared, i.e. the assigned slice is equal to the final window.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description SlicedUnsharedSliceAssigner(int sliceEndIndex, SliceAssigner innerAssigner)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longgetLastWindowEnd(long sliceEnd)Returns the last window which the slice belongs to.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.table.runtime.operators.window.slicing.SliceAssigner
assignSliceEnd, expiredSlices, getSliceEndInterval, getWindowStart, isEventTime
-
-
-
-
Constructor Detail
-
SlicedUnsharedSliceAssigner
public SlicedUnsharedSliceAssigner(int sliceEndIndex, SliceAssigner innerAssigner)
-
-
Method Detail
-
getLastWindowEnd
public long getLastWindowEnd(long sliceEnd)
Description copied from interface:SliceAssignerReturns the last window which the slice belongs to. The window and slices are both identified by the end timestamp.- Specified by:
getLastWindowEndin interfaceSliceAssigner
-
-