All Known Subinterfaces:

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

All Known Implementing Classes:

AbstractKeyedStateBackend, AsyncKeyedStateBackendAdaptor, BatchExecutionKeyedStateBackend, ChangelogKeyedStateBackend, ForStDBPriorityQueueSetFactory, ForStKeyedStateBackend, ForStSyncKeyedStateBackend, HeapKeyedStateBackend, HeapPriorityQueueSetFactory, RocksDBKeyedStateBackend, RocksDBPriorityQueueSetFactory
```
public interface PriorityQueueSetFactory
```
Factory for KeyGroupedInternalPriorityQueue instances.

Method Summary

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method	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.

Interface PriorityQueueSetFactory

Method Summary

Method Detail

create

create