org.apache.flink.contrib.streaming.state

Class RocksDBConfigurableOptions

java.lang.Object

org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions

All Implemented Interfaces:

Serializable

public class RocksDBConfigurableOptions
extends Object
implements Serializable

This class contains the configuration options for the EmbeddedRocksDBStateBackend.

Currently, RocksDB's options would be configured by values here on top of PredefinedOptions, and then a user-defined RocksDBOptionsFactory may override the configurations here.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<MemorySize>	BLOCK_CACHE_SIZE
static ConfigOption<MemorySize>	BLOCK_SIZE
static ConfigOption<Double>	BLOOM_FILTER_BITS_PER_KEY
static ConfigOption<Boolean>	BLOOM_FILTER_BLOCK_BASED_MODE
static ConfigOption<org.rocksdb.CompactionStyle>	COMPACTION_STYLE
static ConfigOption<String>	LOG_DIR
static ConfigOption<Integer>	LOG_FILE_NUM
static ConfigOption<org.rocksdb.InfoLogLevel>	LOG_LEVEL
static ConfigOption<MemorySize>	LOG_MAX_FILE_SIZE
static ConfigOption<Integer>	MAX_BACKGROUND_THREADS
static ConfigOption<Integer>	MAX_OPEN_FILES
static ConfigOption<MemorySize>	MAX_SIZE_LEVEL_BASE
static ConfigOption<Integer>	MAX_WRITE_BUFFER_NUMBER
static ConfigOption<MemorySize>	METADATA_BLOCK_SIZE
static ConfigOption<Integer>	MIN_WRITE_BUFFER_NUMBER_TO_MERGE
static ConfigOption<Double>	RESTORE_OVERLAP_FRACTION_THRESHOLD
static ConfigOption<MemorySize>	TARGET_FILE_SIZE_BASE
static ConfigOption<Boolean>	USE_BLOOM_FILTER
static ConfigOption<Boolean>	USE_DYNAMIC_LEVEL_SIZE
static ConfigOption<MemorySize>	WRITE_BATCH_SIZE
static ConfigOption<MemorySize>	WRITE_BUFFER_SIZE

Constructor Summary

Constructors

Constructor and Description
RocksDBConfigurableOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

MAX_BACKGROUND_THREADS

public static final ConfigOption<Integer> MAX_BACKGROUND_THREADS

MAX_OPEN_FILES

public static final ConfigOption<Integer> MAX_OPEN_FILES

LOG_MAX_FILE_SIZE

public static final ConfigOption<MemorySize> LOG_MAX_FILE_SIZE

LOG_FILE_NUM

public static final ConfigOption<Integer> LOG_FILE_NUM

LOG_DIR

public static final ConfigOption<String> LOG_DIR

LOG_LEVEL

public static final ConfigOption<org.rocksdb.InfoLogLevel> LOG_LEVEL

COMPACTION_STYLE

public static final ConfigOption<org.rocksdb.CompactionStyle> COMPACTION_STYLE

USE_DYNAMIC_LEVEL_SIZE

public static final ConfigOption<Boolean> USE_DYNAMIC_LEVEL_SIZE

TARGET_FILE_SIZE_BASE

public static final ConfigOption<MemorySize> TARGET_FILE_SIZE_BASE

MAX_SIZE_LEVEL_BASE

public static final ConfigOption<MemorySize> MAX_SIZE_LEVEL_BASE

WRITE_BUFFER_SIZE

public static final ConfigOption<MemorySize> WRITE_BUFFER_SIZE

MAX_WRITE_BUFFER_NUMBER

public static final ConfigOption<Integer> MAX_WRITE_BUFFER_NUMBER

MIN_WRITE_BUFFER_NUMBER_TO_MERGE

public static final ConfigOption<Integer> MIN_WRITE_BUFFER_NUMBER_TO_MERGE

BLOCK_SIZE

public static final ConfigOption<MemorySize> BLOCK_SIZE

METADATA_BLOCK_SIZE

public static final ConfigOption<MemorySize> METADATA_BLOCK_SIZE

BLOCK_CACHE_SIZE

public static final ConfigOption<MemorySize> BLOCK_CACHE_SIZE

WRITE_BATCH_SIZE

public static final ConfigOption<MemorySize> WRITE_BATCH_SIZE

USE_BLOOM_FILTER

public static final ConfigOption<Boolean> USE_BLOOM_FILTER

BLOOM_FILTER_BITS_PER_KEY

public static final ConfigOption<Double> BLOOM_FILTER_BITS_PER_KEY

BLOOM_FILTER_BLOCK_BASED_MODE

public static final ConfigOption<Boolean> BLOOM_FILTER_BLOCK_BASED_MODE

RESTORE_OVERLAP_FRACTION_THRESHOLD

public static final ConfigOption<Double> RESTORE_OVERLAP_FRACTION_THRESHOLD

Constructor Detail

RocksDBConfigurableOptions

public RocksDBConfigurableOptions()