Uses of Class
org.apache.flink.runtime.state.heap.HeapPriorityQueueSet

Packages that use HeapPriorityQueueSet

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

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

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

Constructors in org.apache.flink.runtime.state.heap with parameters of type HeapPriorityQueueSet

Constructor and Description
HeapPriorityQueueSnapshotRestoreWrapper(HeapPriorityQueueSet<T> priorityQueue, RegisteredPriorityQueueStateBackendMetaInfo<T> metaInfo, KeyExtractorFunction<T> keyExtractorFunction, KeyGroupRange localKeyGroupRange, int totalKeyGroups)