Uses of Interface
org.apache.flink.runtime.state.KeyGroupedInternalPriorityQueue

Packages that use KeyGroupedInternalPriorityQueue

Package	Description
org.apache.flink.runtime.state
org.apache.flink.runtime.state.heap	This package contains the classes for key/value state backends that store the state on the JVM heap as objects.

Uses of KeyGroupedInternalPriorityQueue in org.apache.flink.runtime.state

Methods in org.apache.flink.runtime.state that return KeyGroupedInternalPriorityQueue

Modifier and Type	Method	Description
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	PriorityQueueSetFactory.create(String stateName, org.apache.flink.api.common.typeutils.TypeSerializer<T> byteOrderedElementSerializer)	Creates a KeyGroupedInternalPriorityQueue.
default <T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	PriorityQueueSetFactory.create(String stateName, org.apache.flink.api.common.typeutils.TypeSerializer<T> byteOrderedElementSerializer, boolean allowFutureMetadataUpdates)	Creates a KeyGroupedInternalPriorityQueue.
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	HeapPriorityQueuesManager.createOrUpdate(String stateName, org.apache.flink.api.common.typeutils.TypeSerializer<T> byteOrderedElementSerializer)
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	HeapPriorityQueuesManager.createOrUpdate(String stateName, org.apache.flink.api.common.typeutils.TypeSerializer<T> byteOrderedElementSerializer, boolean allowFutureMetadataUpdates)

Uses of KeyGroupedInternalPriorityQueue in org.apache.flink.runtime.state.heap

Classes in org.apache.flink.runtime.state.heap that implement KeyGroupedInternalPriorityQueue

Modifier and Type	Class	Description
class	HeapPriorityQueueSet<T extends HeapPriorityQueueElement>	A heap-based priority queue with set semantics, based on HeapPriorityQueue.
class	KeyGroupPartitionedPriorityQueue<T,PQ extends InternalPriorityQueue<T> & HeapPriorityQueueElement>	This implementation of InternalPriorityQueue is internally partitioned into sub-queues per key-group and essentially works as a heap-of-heaps.

Methods in org.apache.flink.runtime.state.heap that return KeyGroupedInternalPriorityQueue

Modifier and Type	Method	Description
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	HeapKeyedStateBackend.create(String stateName, org.apache.flink.api.common.typeutils.TypeSerializer<T> byteOrderedElementSerializer)
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	HeapKeyedStateBackend.create(String stateName, org.apache.flink.api.common.typeutils.TypeSerializer<T> byteOrderedElementSerializer, boolean allowFutureMetadataUpdates)