Uses of Interface
org.apache.flink.runtime.state.heap.HeapPriorityQueueElement

Packages that use HeapPriorityQueueElement

Package	Description
org.apache.flink.contrib.streaming.state
org.apache.flink.runtime.source.coordinator
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 HeapPriorityQueueElement in org.apache.flink.contrib.streaming.state

Classes in org.apache.flink.contrib.streaming.state with type parameters of type HeapPriorityQueueElement

Modifier and Type	Class and Description
class	RocksDBCachingPriorityQueueSet<E extends HeapPriorityQueueElement> A priority queue with set semantics, implemented on top of RocksDB.

Classes in org.apache.flink.contrib.streaming.state that implement HeapPriorityQueueElement

Modifier and Type	Class and Description
class	RocksDBCachingPriorityQueueSet<E extends HeapPriorityQueueElement> A priority queue with set semantics, implemented on top of RocksDB.

Methods in org.apache.flink.contrib.streaming.state with type parameters of type HeapPriorityQueueElement

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

Uses of HeapPriorityQueueElement in org.apache.flink.runtime.source.coordinator

Classes in org.apache.flink.runtime.source.coordinator that implement HeapPriorityQueueElement

Modifier and Type	Class and Description
static class	SourceCoordinator.WatermarkElement The watermark element for HeapPriorityQueue.

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

Methods in org.apache.flink.runtime.state with type parameters of type HeapPriorityQueueElement

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 HeapPriorityQueueElement in org.apache.flink.runtime.state.heap

Classes in org.apache.flink.runtime.state.heap with type parameters of type HeapPriorityQueueElement

Modifier and Type	Class and Description
class	AbstractHeapPriorityQueue<T extends HeapPriorityQueueElement> Abstract base class for heap (object array) based implementations of priority queues, with support for fast deletes via HeapPriorityQueueElement.
class	HeapPriorityQueue<T extends HeapPriorityQueueElement> Basic heap-based priority queue for HeapPriorityQueueElement objects.
class	HeapPriorityQueueSet<T extends HeapPriorityQueueElement> A heap-based priority queue with set semantics, based on HeapPriorityQueue.
class	HeapPriorityQueueSnapshotRestoreWrapper<T extends HeapPriorityQueueElement> This wrapper combines a HeapPriorityQueue with backend meta data.
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.
static interface	KeyGroupPartitionedPriorityQueue.PartitionQueueSetFactory<T,PQS extends InternalPriorityQueue<T> & HeapPriorityQueueElement> Factory that produces the sub-queues that represent the partitions of a KeyGroupPartitionedPriorityQueue.

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

Modifier and Type	Class and Description
class	AbstractHeapPriorityQueueElement Abstract base class for HeapPriorityQueueElement.

Fields in org.apache.flink.runtime.state.heap declared as HeapPriorityQueueElement

Modifier and Type	Field and Description
protected T[]	AbstractHeapPriorityQueue.queue The array that represents the heap-organized priority queue.

Methods in org.apache.flink.runtime.state.heap with type parameters of type HeapPriorityQueueElement

Modifier and Type	Method and Description
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> HeapPriorityQueueSet<T>	HeapPriorityQueueSetFactory.create(String stateName, TypeSerializer<T> byteOrderedElementSerializer)
<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 HeapPriorityQueueElement in org.apache.flink.state.changelog

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

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

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

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

Modifier and Type	Method and Description
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	ChangelogMigrationRestoreTarget.createPqState(String stateName, TypeSerializer<T> byteOrderedElementSerializer)
<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.

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

Classes in org.apache.flink.streaming.api.operators that implement HeapPriorityQueueElement

Modifier and Type	Class and Description
class	TimerHeapInternalTimer<K,N> Implementation of InternalTimer to use with a HeapPriorityQueueSet.

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

Methods in org.apache.flink.streaming.api.operators.sorted.state with type parameters of type HeapPriorityQueueElement

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