public interface KeyGroupedInternalPriorityQueue<T> extends InternalPriorityQueue<T>
InternalPriorityQueueand 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|
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–2022 The Apache Software Foundation. All rights reserved.