Package org.apache.flink.contrib.streaming.state

Class RocksDBPriorityQueueConfig

java.lang.Object

org.apache.flink.contrib.streaming.state.RocksDBPriorityQueueConfig

All Implemented Interfaces:

Serializable

public class RocksDBPriorityQueueConfig
extends Object
implements Serializable

The configuration of rocksDB priority queue state implementation.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
RocksDBPriorityQueueConfig()
RocksDBPriorityQueueConfig(EmbeddedRocksDBStateBackend.PriorityQueueStateType priorityQueueStateType, int rocksDBPriorityQueueSetCacheSize)

Method Summary

Modifier and Type	Method	Description
static RocksDBPriorityQueueConfig	buildWithPriorityQueueType(EmbeddedRocksDBStateBackend.PriorityQueueStateType type)
static RocksDBPriorityQueueConfig	fromOtherAndConfiguration(RocksDBPriorityQueueConfig other, org.apache.flink.configuration.ReadableConfig config)
EmbeddedRocksDBStateBackend.PriorityQueueStateType	getPriorityQueueStateType()	Gets the type of the priority queue state.
int	getRocksDBPriorityQueueSetCacheSize()	Gets the cache size of rocksDB priority queue set.
void	setPriorityQueueStateType(EmbeddedRocksDBStateBackend.PriorityQueueStateType type)

Methods inherited from class java.lang.Object

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

Constructor Detail

RocksDBPriorityQueueConfig

public RocksDBPriorityQueueConfig()

RocksDBPriorityQueueConfig

public RocksDBPriorityQueueConfig(EmbeddedRocksDBStateBackend.PriorityQueueStateType priorityQueueStateType,
                                  int rocksDBPriorityQueueSetCacheSize)

Method Detail

getPriorityQueueStateType

public EmbeddedRocksDBStateBackend.PriorityQueueStateType getPriorityQueueStateType()

Gets the type of the priority queue state. It will fall back to the default value if it is not explicitly set.

setPriorityQueueStateType

public void setPriorityQueueStateType(EmbeddedRocksDBStateBackend.PriorityQueueStateType type)

getRocksDBPriorityQueueSetCacheSize

public int getRocksDBPriorityQueueSetCacheSize()

Gets the cache size of rocksDB priority queue set. It will fall back to the default value if it is not explicitly set.

fromOtherAndConfiguration

public static RocksDBPriorityQueueConfig fromOtherAndConfiguration(RocksDBPriorityQueueConfig other,
                                                                   org.apache.flink.configuration.ReadableConfig config)

buildWithPriorityQueueType

public static RocksDBPriorityQueueConfig buildWithPriorityQueueType(EmbeddedRocksDBStateBackend.PriorityQueueStateType type)