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.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.streaming.api.operators

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 & Keyed> KeyGroupedInternalPriorityQueue<T>	RocksDBPriorityQueueSetFactory.create(String stateName, TypeSerializer<T> byteOrderedElementSerializer)
<T extends HeapPriorityQueueElement & PriorityComparable & Keyed> KeyGroupedInternalPriorityQueue<T>	RocksDBKeyedStateBackend.create(String stateName, TypeSerializer<T> byteOrderedElementSerializer)

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 & Keyed> KeyGroupedInternalPriorityQueue<T>	PriorityQueueSetFactory.create(String stateName, TypeSerializer<T> byteOrderedElementSerializer) Creates a KeyGroupedInternalPriorityQueue.

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.

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 & Keyed> HeapPriorityQueueSet<T>	HeapPriorityQueueSetFactory.create(String stateName, TypeSerializer<T> byteOrderedElementSerializer)
<T extends HeapPriorityQueueElement & PriorityComparable & Keyed> KeyGroupedInternalPriorityQueue<T>	HeapKeyedStateBackend.create(String stateName, TypeSerializer<T> byteOrderedElementSerializer)

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.