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

Class RocksDBConfigurableOptions

java.lang.Object

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

All Implemented Interfaces:

Serializable

@PublicEvolving
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	Description
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>	BLOCK_CACHE_SIZE
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>	BLOCK_SIZE
static org.apache.flink.configuration.ConfigOption<Double>	BLOOM_FILTER_BITS_PER_KEY
static org.apache.flink.configuration.ConfigOption<Boolean>	BLOOM_FILTER_BLOCK_BASED_MODE
static org.apache.flink.configuration.ConfigOption<org.rocksdb.CompactionStyle>	COMPACTION_STYLE
static org.apache.flink.configuration.ConfigOption<List<org.rocksdb.CompressionType>>	COMPRESSION_PER_LEVEL
static org.apache.flink.configuration.ConfigOption<Boolean>	INCREMENTAL_RESTORE_ASYNC_COMPACT_AFTER_RESCALE
static org.apache.flink.configuration.ConfigOption<String>	LOG_DIR
static org.apache.flink.configuration.ConfigOption<Integer>	LOG_FILE_NUM
static org.apache.flink.configuration.ConfigOption<org.rocksdb.InfoLogLevel>	LOG_LEVEL
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>	LOG_MAX_FILE_SIZE
static org.apache.flink.configuration.ConfigOption<Integer>	MAX_BACKGROUND_THREADS
static org.apache.flink.configuration.ConfigOption<Integer>	MAX_OPEN_FILES
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>	MAX_SIZE_LEVEL_BASE
static org.apache.flink.configuration.ConfigOption<Integer>	MAX_WRITE_BUFFER_NUMBER
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>	METADATA_BLOCK_SIZE
static org.apache.flink.configuration.ConfigOption<Integer>	MIN_WRITE_BUFFER_NUMBER_TO_MERGE
static org.apache.flink.configuration.ConfigOption<Double>	RESTORE_OVERLAP_FRACTION_THRESHOLD
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>	TARGET_FILE_SIZE_BASE
static org.apache.flink.configuration.ConfigOption<Boolean>	USE_BLOOM_FILTER
static org.apache.flink.configuration.ConfigOption<Boolean>	USE_DELETE_FILES_IN_RANGE_DURING_RESCALING
static org.apache.flink.configuration.ConfigOption<Boolean>	USE_DYNAMIC_LEVEL_SIZE
static org.apache.flink.configuration.ConfigOption<Boolean>	USE_INGEST_DB_RESTORE_MODE
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>	WRITE_BATCH_SIZE
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>	WRITE_BUFFER_SIZE

Constructor Summary

Constructors

Constructor	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 org.apache.flink.configuration.ConfigOption<Integer> MAX_BACKGROUND_THREADS

MAX_OPEN_FILES

public static final org.apache.flink.configuration.ConfigOption<Integer> MAX_OPEN_FILES

LOG_MAX_FILE_SIZE

public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> LOG_MAX_FILE_SIZE

LOG_FILE_NUM

public static final org.apache.flink.configuration.ConfigOption<Integer> LOG_FILE_NUM

LOG_DIR

public static final org.apache.flink.configuration.ConfigOption<String> LOG_DIR

LOG_LEVEL

public static final org.apache.flink.configuration.ConfigOption<org.rocksdb.InfoLogLevel> LOG_LEVEL

COMPACTION_STYLE

public static final org.apache.flink.configuration.ConfigOption<org.rocksdb.CompactionStyle> COMPACTION_STYLE

USE_DYNAMIC_LEVEL_SIZE

public static final org.apache.flink.configuration.ConfigOption<Boolean> USE_DYNAMIC_LEVEL_SIZE

COMPRESSION_PER_LEVEL

public static final org.apache.flink.configuration.ConfigOption<List<org.rocksdb.CompressionType>> COMPRESSION_PER_LEVEL

TARGET_FILE_SIZE_BASE

public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> TARGET_FILE_SIZE_BASE

MAX_SIZE_LEVEL_BASE

public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> MAX_SIZE_LEVEL_BASE

WRITE_BUFFER_SIZE

public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> WRITE_BUFFER_SIZE

MAX_WRITE_BUFFER_NUMBER

public static final org.apache.flink.configuration.ConfigOption<Integer> MAX_WRITE_BUFFER_NUMBER

MIN_WRITE_BUFFER_NUMBER_TO_MERGE

public static final org.apache.flink.configuration.ConfigOption<Integer> MIN_WRITE_BUFFER_NUMBER_TO_MERGE

BLOCK_SIZE

public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> BLOCK_SIZE

METADATA_BLOCK_SIZE

public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> METADATA_BLOCK_SIZE

BLOCK_CACHE_SIZE

public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> BLOCK_CACHE_SIZE

WRITE_BATCH_SIZE

public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> WRITE_BATCH_SIZE

USE_BLOOM_FILTER

public static final org.apache.flink.configuration.ConfigOption<Boolean> USE_BLOOM_FILTER

BLOOM_FILTER_BITS_PER_KEY

public static final org.apache.flink.configuration.ConfigOption<Double> BLOOM_FILTER_BITS_PER_KEY

BLOOM_FILTER_BLOCK_BASED_MODE

public static final org.apache.flink.configuration.ConfigOption<Boolean> BLOOM_FILTER_BLOCK_BASED_MODE

RESTORE_OVERLAP_FRACTION_THRESHOLD

public static final org.apache.flink.configuration.ConfigOption<Double> RESTORE_OVERLAP_FRACTION_THRESHOLD

USE_INGEST_DB_RESTORE_MODE

public static final org.apache.flink.configuration.ConfigOption<Boolean> USE_INGEST_DB_RESTORE_MODE

INCREMENTAL_RESTORE_ASYNC_COMPACT_AFTER_RESCALE

public static final org.apache.flink.configuration.ConfigOption<Boolean> INCREMENTAL_RESTORE_ASYNC_COMPACT_AFTER_RESCALE

USE_DELETE_FILES_IN_RANGE_DURING_RESCALING

public static final org.apache.flink.configuration.ConfigOption<Boolean> USE_DELETE_FILES_IN_RANGE_DURING_RESCALING

Constructor Detail

RocksDBConfigurableOptions

public RocksDBConfigurableOptions()