public static final class SliceAssigners.CumulativeSliceAssigner extends Object implements SliceSharedAssigner
SliceAssigner
for cumulative windows.SliceSharedAssigner.MergeCallback
Modifier | Constructor and Description |
---|---|
protected |
CumulativeSliceAssigner(int rowtimeIndex,
java.time.ZoneId shiftTimeZone,
long maxSize,
long step,
long offset) |
Modifier and Type | Method and Description |
---|---|
long |
assignSliceEnd(long timestamp) |
Iterable<Long> |
expiredSlices(long windowEnd)
Returns an iterator of slices to expire when the given window is emitted.
|
long |
getLastWindowEnd(long sliceEnd)
Returns the last window which the slice belongs to.
|
long |
getSliceEndInterval()
Returns the interval of slice ends, i.e.
|
long |
getWindowStart(long windowEnd)
Returns the corresponding window start timestamp of the given window end timestamp.
|
void |
mergeSlices(long sliceEnd,
SliceSharedAssigner.MergeCallback callback)
Determines which slices (if any) should be merged.
|
Optional<Long> |
nextTriggerWindow(long windowEnd,
java.util.function.Supplier<Boolean> isWindowEmpty)
Returns the optional end timestamp of next window which should be triggered.
|
SliceAssigners.CumulativeSliceAssigner |
withOffset(java.time.Duration offset)
Creates a new
SliceAssigners.CumulativeSliceAssigner with a new specified offset. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
assignSliceEnd, isEventTime
protected CumulativeSliceAssigner(int rowtimeIndex, java.time.ZoneId shiftTimeZone, long maxSize, long step, long offset)
public SliceAssigners.CumulativeSliceAssigner withOffset(java.time.Duration offset)
SliceAssigners.CumulativeSliceAssigner
with a new specified offset.public long assignSliceEnd(long timestamp)
public long getLastWindowEnd(long sliceEnd)
SliceAssigner
getLastWindowEnd
in interface SliceAssigner
public long getWindowStart(long windowEnd)
SliceAssigner
getWindowStart
in interface SliceAssigner
public Iterable<Long> expiredSlices(long windowEnd)
SliceAssigner
expiredSlices
in interface SliceAssigner
windowEnd
- the end timestamp of window emitted.public long getSliceEndInterval()
SliceAssigner
getSliceEndInterval
in interface SliceAssigner
public void mergeSlices(long sliceEnd, SliceSharedAssigner.MergeCallback callback) throws Exception
SliceSharedAssigner
mergeSlices
in interface SliceSharedAssigner
sliceEnd
- the triggered slice, identified by end timestampcallback
- a callback that can be invoked to signal which slices should be merged.Exception
public Optional<Long> nextTriggerWindow(long windowEnd, java.util.function.Supplier<Boolean> isWindowEmpty)
SliceSharedAssigner
The purpose of this method is avoid register too many timers for each hopping and
cumulative slice, e.g. HOP(1day, 10s) needs register 8640 timers for every slice. In order to
improve this, we only register one timer for the next window. For hopping windows we don't
register next window if current window is empty (i.e. no records in current window). That
means we will have one more unnecessary window triggered for hopping windows if no elements
arrives for a key for a long time. We will skip to emit window result for the triggered empty
window, see SliceSharedWindowAggProcessor.fireWindow(Long)
.
nextTriggerWindow
in interface SliceSharedAssigner
windowEnd
- the current triggered window, identified by end timestampisWindowEmpty
- a supplier that can be invoked to get whether the triggered window is
empty (i.e. no records in the window).Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.