org.apache.flink.runtime.state

Interface PriorityQueueSetFactory

All Known Subinterfaces:

CheckpointableKeyedStateBackend<K>, KeyedStateBackend<K>, TestableKeyedStateBackend<K>

All Known Implementing Classes:

AbstractKeyedStateBackend, BatchExecutionKeyedStateBackend, ChangelogKeyedStateBackend, HeapKeyedStateBackend, HeapPriorityQueueSetFactory, RocksDBKeyedStateBackend, RocksDBPriorityQueueSetFactory

public interface PriorityQueueSetFactory

Factory for KeyGroupedInternalPriorityQueue instances.

Method Summary

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

Method Detail

create

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

Creates a KeyGroupedInternalPriorityQueue.

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.

create

default <T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T> create(@Nonnull
                                                                                                                                  String stateName,
                                                                                                                                  @Nonnull
                                                                                                                                  TypeSerializer<T> byteOrderedElementSerializer,
                                                                                                                                  boolean allowFutureMetadataUpdates)

Creates a KeyGroupedInternalPriorityQueue.

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.

allowFutureMetadataUpdates - whether allow metadata to update in the future or not.

Returns:

the queue with the specified unique name.