public interface KeyGroupedInternalPriorityQueue<T> extends InternalPriorityQueue<T>
InternalPriorityQueue
and the old way in which
timers are written in a snapshot. This interface can probably go away once timer state becomes part of the
keyed state backend snapshot.Modifier and Type | Method and Description |
---|---|
Set<T> |
getSubsetForKeyGroup(int keyGroupId)
Returns the subset of elements in the priority queue that belongs to the given key-group, within the operator's
key-group range.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.