Package org.apache.flink.state.forst

Class ForStOptions

java.lang.Object

org.apache.flink.state.forst.ForStOptions

@Experimental
public class ForStOptions
extends Object

Configuration options for the ForStStateBackend.

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.flink.configuration.ConfigOption<String>	CACHE_DIRECTORY
static org.apache.flink.configuration.ConfigOption<Integer>	CACHE_LRU_ACCESS_BEFORE_PROMOTION
static org.apache.flink.configuration.ConfigOption<Integer>	CACHE_LRU_PROMOTION_LIMIT
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>	CACHE_RESERVED_SIZE
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>	CACHE_SIZE_BASE_LIMIT
static org.apache.flink.configuration.ConfigOption<Boolean>	EXECUTOR_COORDINATOR_INLINE
static org.apache.flink.configuration.ConfigOption<Integer>	EXECUTOR_READ_IO_PARALLELISM
static org.apache.flink.configuration.ConfigOption<Boolean>	EXECUTOR_WRITE_IO_INLINE
static org.apache.flink.configuration.ConfigOption<Integer>	EXECUTOR_WRITE_IO_PARALLELISM
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>	FIX_PER_SLOT_MEMORY_SIZE
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>	FIX_PER_TM_MEMORY_SIZE
static org.apache.flink.configuration.ConfigOption<Integer>	FORST_TIMER_SERVICE_FACTORY_CACHE_SIZE	The cache size per key-group for ForSt timer service factory implementation.
static org.apache.flink.configuration.ConfigOption<Double>	HIGH_PRIORITY_POOL_RATIO
static org.apache.flink.configuration.ConfigOption<String>	LOCAL_DIRECTORIES	The local directory (on the TaskManager) where ForSt puts some meta files.
static org.apache.flink.configuration.ConfigOption<String>	OPTIONS_FACTORY	The options factory class for ForSt to create DBOptions and ColumnFamilyOptions.
static org.apache.flink.configuration.ConfigOption<String>	PRIMARY_DIRECTORY	The remote directory where ForSt puts its SST files.
static org.apache.flink.configuration.ConfigOption<Boolean>	SYNC_ENFORCE_LOCAL
static org.apache.flink.configuration.ConfigOption<ForStStateBackend.PriorityQueueStateType>	TIMER_SERVICE_FACTORY	Choice of timer service implementation.
static org.apache.flink.configuration.ConfigOption<Boolean>	USE_MANAGED_MEMORY
static org.apache.flink.configuration.ConfigOption<Boolean>	USE_PARTITIONED_INDEX_FILTERS
static org.apache.flink.configuration.ConfigOption<Double>	WRITE_BUFFER_RATIO

Constructor Summary

Constructors

Constructor	Description
ForStOptions()

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 org.apache.flink.configuration.ConfigOption<String> LOCAL_DIRECTORIES

The local directory (on the TaskManager) where ForSt puts some meta files.

PRIMARY_DIRECTORY

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

The remote directory where ForSt puts its SST files.

SYNC_ENFORCE_LOCAL

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

CACHE_DIRECTORY

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

CACHE_SIZE_BASE_LIMIT

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

CACHE_RESERVED_SIZE

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

CACHE_LRU_ACCESS_BEFORE_PROMOTION

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

CACHE_LRU_PROMOTION_LIMIT

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

OPTIONS_FACTORY

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

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

USE_MANAGED_MEMORY

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

FIX_PER_SLOT_MEMORY_SIZE

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

FIX_PER_TM_MEMORY_SIZE

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

WRITE_BUFFER_RATIO

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

HIGH_PRIORITY_POOL_RATIO

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

USE_PARTITIONED_INDEX_FILTERS

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

TIMER_SERVICE_FACTORY

public static final org.apache.flink.configuration.ConfigOption<ForStStateBackend.PriorityQueueStateType> TIMER_SERVICE_FACTORY

Choice of timer service implementation.

FORST_TIMER_SERVICE_FACTORY_CACHE_SIZE

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

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

EXECUTOR_COORDINATOR_INLINE

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

EXECUTOR_WRITE_IO_INLINE

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

EXECUTOR_READ_IO_PARALLELISM

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

EXECUTOR_WRITE_IO_PARALLELISM

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

Constructor Detail

ForStOptions

public ForStOptions()