KeyGroupedInternalPriorityQueue (Flink : 2.0-SNAPSHOT API)

All Superinterfaces:

InternalPriorityQueue<T>

All Known Implementing Classes:

ChangelogKeyGroupedPriorityQueue, HeapPriorityQueueSet, KeyGroupPartitionedPriorityQueue
```
public interface KeyGroupedInternalPriorityQueue<T>
extends InternalPriorityQueue<T>
```
This interface exists as (temporary) adapter between the new 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.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	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.

Methods inherited from interface org.apache.flink.runtime.state.InternalPriorityQueue
add, addAll, isEmpty, iterator, peek, poll, remove, size

- Method Detail
  - getSubsetForKeyGroup
```
@Nonnull
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.