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