Package org.apache.flink.state.rocksdb

Class RocksDBOptions

java.lang.Object

org.apache.flink.state.rocksdb.RocksDBOptions

Direct Known Subclasses:

RocksDBOptions

@PublicEvolving
public class RocksDBOptions
extends Object

Configuration options for the RocksDB backend.

Field Summary

Fields

Modifier and Type	Field	Description
static ConfigOption<Integer>	CHECKPOINT_TRANSFER_THREAD_NUM	The number of threads used to transfer (download and upload) files in RocksDBStateBackend.
static ConfigOption<MemorySize>	FIX_PER_SLOT_MEMORY_SIZE
static ConfigOption<MemorySize>	FIX_PER_TM_MEMORY_SIZE
static ConfigOption<Double>	HIGH_PRIORITY_POOL_RATIO
static ConfigOption<String>	LOCAL_DIRECTORIES	The local directory (on the TaskManager) where RocksDB puts its files.
static ConfigOption<String>	OPTIONS_FACTORY	The options factory class for RocksDB to create DBOptions and ColumnFamilyOptions.
static ConfigOption<String>	PREDEFINED_OPTIONS	The predefined settings for RocksDB DBOptions and ColumnFamilyOptions by Flink community.
static ConfigOption<Integer>	ROCKSDB_TIMER_SERVICE_FACTORY_CACHE_SIZE	The cache size per key-group for ROCKSDB timer service factory implementation.
static ConfigOption<EmbeddedRocksDBStateBackend.PriorityQueueStateType>	TIMER_SERVICE_FACTORY	Choice of timer service implementation.
static ConfigOption<Boolean>	USE_MANAGED_MEMORY
static ConfigOption<Boolean>	USE_PARTITIONED_INDEX_FILTERS
static ConfigOption<Double>	WRITE_BUFFER_RATIO

Constructor Summary

Constructors

Constructor	Description
RocksDBOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

LOCAL_DIRECTORIES

public static final ConfigOption<String> LOCAL_DIRECTORIES

The local directory (on the TaskManager) where RocksDB puts its files.

TIMER_SERVICE_FACTORY

public static final ConfigOption<EmbeddedRocksDBStateBackend.PriorityQueueStateType> TIMER_SERVICE_FACTORY

Choice of timer service implementation.

ROCKSDB_TIMER_SERVICE_FACTORY_CACHE_SIZE

public static final ConfigOption<Integer> ROCKSDB_TIMER_SERVICE_FACTORY_CACHE_SIZE

The cache size per key-group for ROCKSDB timer service factory implementation.

CHECKPOINT_TRANSFER_THREAD_NUM

public static final ConfigOption<Integer> CHECKPOINT_TRANSFER_THREAD_NUM

The number of threads used to transfer (download and upload) files in RocksDBStateBackend.

PREDEFINED_OPTIONS

public static final ConfigOption<String> PREDEFINED_OPTIONS

The predefined settings for RocksDB DBOptions and ColumnFamilyOptions by Flink community.

OPTIONS_FACTORY

public static final ConfigOption<String> OPTIONS_FACTORY

The options factory class for RocksDB to create DBOptions and ColumnFamilyOptions.

USE_MANAGED_MEMORY

public static final ConfigOption<Boolean> USE_MANAGED_MEMORY

FIX_PER_SLOT_MEMORY_SIZE

public static final ConfigOption<MemorySize> FIX_PER_SLOT_MEMORY_SIZE

FIX_PER_TM_MEMORY_SIZE

public static final ConfigOption<MemorySize> FIX_PER_TM_MEMORY_SIZE

WRITE_BUFFER_RATIO

public static final ConfigOption<Double> WRITE_BUFFER_RATIO

HIGH_PRIORITY_POOL_RATIO

public static final ConfigOption<Double> HIGH_PRIORITY_POOL_RATIO

USE_PARTITIONED_INDEX_FILTERS

public static final ConfigOption<Boolean> USE_PARTITIONED_INDEX_FILTERS

Constructor Detail

RocksDBOptions

public RocksDBOptions()