public static final class SliceAssigners.SlicedUnsharedSliceAssigner extends Object implements SliceUnsharedAssigner
SliceAssigner
for elements have been attached slice end timestamp, but the slices
are not shared, i.e. the assigned slice is equal to the final window.Constructor and Description |
---|
SlicedUnsharedSliceAssigner(int sliceEndIndex,
SliceAssigner innerAssigner) |
Modifier and Type | Method and Description |
---|---|
String |
getDescription()
Returns a description of this window assigner.
|
long |
getLastWindowEnd(long sliceEnd)
Returns the last window which the slice belongs to.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
assignSliceEnd, expiredSlices, getSliceEndInterval, getWindowStart
isEventTime
public SlicedUnsharedSliceAssigner(int sliceEndIndex, SliceAssigner innerAssigner)
public long getLastWindowEnd(long sliceEnd)
SliceAssigner
getLastWindowEnd
in interface SliceAssigner
public String getDescription()
WindowAssigner
getDescription
in interface WindowAssigner
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.