org.apache.flink.contrib.streaming.state

Class RocksDBPriorityQueueSetFactory

java.lang.Object

org.apache.flink.contrib.streaming.state.RocksDBPriorityQueueSetFactory

All Implemented Interfaces:

PriorityQueueSetFactory

public class RocksDBPriorityQueueSetFactory
extends Object
implements PriorityQueueSetFactory

Encapsulates the logic and resources in connection with creating priority queue state structures, for RocksDB backend.

Method Summary

Modifier and Type	Method and Description
<T extends HeapPriorityQueueElement & PriorityComparable & Keyed> KeyGroupedInternalPriorityQueue<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

Method Detail

create

@Nonnull
public <T extends HeapPriorityQueueElement & PriorityComparable & Keyed> KeyGroupedInternalPriorityQueue<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.