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

Packages that use KeyGroupedInternalPriorityQueue

Package	Description
org.apache.flink.contrib.streaming.state
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.
org.apache.flink.state.changelog
org.apache.flink.state.changelog.restore
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.sorted.state

Uses of KeyGroupedInternalPriorityQueue in org.apache.flink.contrib.streaming.state

Methods in org.apache.flink.contrib.streaming.state that return KeyGroupedInternalPriorityQueue

Modifier and Type	Method and Description
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	RocksDBKeyedStateBackend.create(String stateName, TypeSerializer<T> byteOrderedElementSerializer)
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	RocksDBPriorityQueueSetFactory.create(String stateName, TypeSerializer<T> byteOrderedElementSerializer)
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	RocksDBKeyedStateBackend.create(String stateName, TypeSerializer<T> byteOrderedElementSerializer, boolean allowFutureMetadataUpdates)
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	RocksDBPriorityQueueSetFactory.create(String stateName, TypeSerializer<T> byteOrderedElementSerializer, boolean allowFutureMetadataUpdates)

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

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

Modifier and Type	Method and Description
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	PriorityQueueSetFactory.create(String stateName, TypeSerializer<T> byteOrderedElementSerializer) Creates a KeyGroupedInternalPriorityQueue.
default <T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	PriorityQueueSetFactory.create(String stateName, TypeSerializer<T> byteOrderedElementSerializer, boolean allowFutureMetadataUpdates) Creates a KeyGroupedInternalPriorityQueue.
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	HeapPriorityQueuesManager.createOrUpdate(String stateName, TypeSerializer<T> byteOrderedElementSerializer)
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	HeapPriorityQueuesManager.createOrUpdate(String stateName, 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 and 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 and Description
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	HeapKeyedStateBackend.create(String stateName, TypeSerializer<T> byteOrderedElementSerializer)
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	HeapKeyedStateBackend.create(String stateName, TypeSerializer<T> byteOrderedElementSerializer, boolean allowFutureMetadataUpdates)

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

Classes in org.apache.flink.state.changelog that implement KeyGroupedInternalPriorityQueue

Modifier and Type	Class and Description
class	ChangelogKeyGroupedPriorityQueue<T> A KeyGroupedInternalPriorityQueue that keeps state on the underlying delegated KeyGroupedInternalPriorityQueue as well as on the state change log.

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

Modifier and Type	Method and Description
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	ChangelogKeyedStateBackend.create(String stateName, TypeSerializer<T> byteOrderedElementSerializer)

Methods in org.apache.flink.state.changelog with parameters of type KeyGroupedInternalPriorityQueue

Modifier and Type	Method and Description
<T> ChangelogKeyGroupedPriorityQueue<T>	ChangelogStateFactory.create(String stateName, KeyGroupedInternalPriorityQueue<T> internalPriorityQueue, StateChangeLogger<T,Void> logger, TypeSerializer<T> serializer)

Constructors in org.apache.flink.state.changelog with parameters of type KeyGroupedInternalPriorityQueue

Constructor and Description
ChangelogKeyGroupedPriorityQueue(KeyGroupedInternalPriorityQueue<T> delegatedPriorityQueue, StateChangeLogger<T,Void> logger, TypeSerializer<T> serializer)

Uses of KeyGroupedInternalPriorityQueue in org.apache.flink.state.changelog.restore

Methods in org.apache.flink.state.changelog.restore that return KeyGroupedInternalPriorityQueue

Modifier and Type	Method and Description
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	ChangelogRestoreTarget.createPqState(String stateName, TypeSerializer<T> byteOrderedElementSerializer) Creates a KeyGroupedInternalPriorityQueue which could be retrieved by #getExistingState(String, BackendStateType) in the restore procedure.
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	ChangelogMigrationRestoreTarget.createPqState(String stateName, TypeSerializer<T> byteOrderedElementSerializer)

Methods in org.apache.flink.state.changelog.restore with parameters of type KeyGroupedInternalPriorityQueue

Modifier and Type	Method and Description
<T> StateChangeApplier	ChangelogApplierFactory.forPriorityQueue(KeyGroupedInternalPriorityQueue<T> priorityQueue, TypeSerializer<T> serializer)

Uses of KeyGroupedInternalPriorityQueue in org.apache.flink.streaming.api.operators

Fields in org.apache.flink.streaming.api.operators declared as KeyGroupedInternalPriorityQueue

Modifier and Type	Field and Description
protected KeyGroupedInternalPriorityQueue<TimerHeapInternalTimer<K,N>>	InternalTimerServiceImpl.eventTimeTimersQueue Event time timers that are currently in-flight.
protected KeyGroupedInternalPriorityQueue<TimerHeapInternalTimer<K,N>>	InternalTimerServiceImpl.processingTimeTimersQueue Processing time timers that are currently in-flight.

Methods in org.apache.flink.streaming.api.operators with parameters of type KeyGroupedInternalPriorityQueue

Modifier and Type	Method and Description
protected void	InternalTimerServiceAsyncImpl.foreachTimer(BiConsumerWithException<N,Long,Exception> consumer, KeyGroupedInternalPriorityQueue<TimerHeapInternalTimer<K,N>> queue) Iterator each timer in the queue, and invoke the consumer.
protected void	InternalTimerServiceImpl.foreachTimer(BiConsumerWithException<N,Long,Exception> consumer, KeyGroupedInternalPriorityQueue<TimerHeapInternalTimer<K,N>> queue)

Uses of KeyGroupedInternalPriorityQueue in org.apache.flink.streaming.api.operators.sorted.state

Methods in org.apache.flink.streaming.api.operators.sorted.state that return KeyGroupedInternalPriorityQueue

Modifier and Type	Method and Description
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	BatchExecutionKeyedStateBackend.create(String stateName, TypeSerializer<T> byteOrderedElementSerializer)