Package org.apache.flink.runtime.state.heap

Class HeapPriorityQueueSetFactory

java.lang.Object

org.apache.flink.runtime.state.heap.HeapPriorityQueueSetFactory

All Implemented Interfaces:

PriorityQueueSetFactory

public class HeapPriorityQueueSetFactory
extends Object
implements PriorityQueueSetFactory

Factory for HeapPriorityQueueSet.

Constructor Summary

Constructors

Constructor	Description
HeapPriorityQueueSetFactory(KeyGroupRange keyGroupRange, int totalKeyGroups, int minimumCapacity)

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.runtime.state.PriorityQueueSetFactory

create

Constructor Detail

HeapPriorityQueueSetFactory

public HeapPriorityQueueSetFactory(@Nonnull
                                   KeyGroupRange keyGroupRange,
                                   @Nonnegative
                                   int totalKeyGroups,
                                   @Nonnegative
                                   int minimumCapacity)

Method Detail

create

@Nonnull
public <T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> HeapPriorityQueueSet<T> create(@Nonnull
                                                                                                                      String stateName,
                                                                                                                      @Nonnull
                                                                                                                      TypeSerializer<T> byteOrderedElementSerializer)

Description copied from interface: PriorityQueueSetFactory

Creates a KeyGroupedInternalPriorityQueue.

Specified by:

create in interface PriorityQueueSetFactory

Type Parameters:

T - type of the stored elements.

Parameters:

stateName - unique name for associated with this queue.

byteOrderedElementSerializer - a serializer that with a format that is lexicographically ordered in alignment with elementPriorityComparator.

Returns:

the queue with the specified unique name.