org.apache.flink.runtime.state

Interface KeyGroupedInternalPriorityQueue<T>

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

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.

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.