Uses of Interface
org.apache.flink.runtime.state.heap.KeyGroupPartitionedPriorityQueue.PartitionQueueSetFactory

Packages that use KeyGroupPartitionedPriorityQueue.PartitionQueueSetFactory

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

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

Constructor and Description
KeyGroupPartitionedPriorityQueue(KeyExtractorFunction<T> keyExtractor, PriorityComparator<T> elementPriorityComparator, KeyGroupPartitionedPriorityQueue.PartitionQueueSetFactory<T,PQ> orderedCacheFactory, KeyGroupRange keyGroupRange, int totalKeyGroups)