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<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	create(String stateName, TypeSerializer<T> byteOrderedElementSerializer) Creates a KeyGroupedInternalPriorityQueue.
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> KeyGroupedInternalPriorityQueue<T>	create(String stateName, TypeSerializer<T> byteOrderedElementSerializer, boolean allowFutureMetadataUpdates) Creates a KeyGroupedInternalPriorityQueue.
int	getCacheSize()

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<? super T> & 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.

create

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

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.

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

Returns:

the queue with the specified unique name.

getCacheSize

@VisibleForTesting
public int getCacheSize()