org.apache.flink.configuration

Class StateBackendOptions

java.lang.Object

org.apache.flink.configuration.StateBackendOptions

public class StateBackendOptions
extends Object

A collection of all configuration options that relate to state backend.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<Boolean>	LATENCY_TRACK_ENABLED
static ConfigOption<Integer>	LATENCY_TRACK_HISTORY_SIZE
static ConfigOption<Integer>	LATENCY_TRACK_SAMPLE_INTERVAL
static ConfigOption<Boolean>	LATENCY_TRACK_STATE_NAME_AS_VARIABLE
static ConfigOption<String>	STATE_BACKEND The checkpoint storage used to store operator state locally within the cluster during execution.

Constructor Summary

Constructors

Constructor and Description
StateBackendOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

STATE_BACKEND

public static final ConfigOption<String> STATE_BACKEND

The checkpoint storage used to store operator state locally within the cluster during execution.

The implementation can be specified either via their shortcut name, or via the class name of a StateBackendFactory. If a StateBackendFactory class name is specified, the factory is instantiated (via its zero-argument constructor) and its StateBackendFactory#createFromConfig(ReadableConfig, ClassLoader) method is called.

Recognized shortcut names are 'hashmap' and 'rocksdb'.

LATENCY_TRACK_ENABLED

public static final ConfigOption<Boolean> LATENCY_TRACK_ENABLED

LATENCY_TRACK_SAMPLE_INTERVAL

public static final ConfigOption<Integer> LATENCY_TRACK_SAMPLE_INTERVAL

LATENCY_TRACK_HISTORY_SIZE

public static final ConfigOption<Integer> LATENCY_TRACK_HISTORY_SIZE

LATENCY_TRACK_STATE_NAME_AS_VARIABLE

public static final ConfigOption<Boolean> LATENCY_TRACK_STATE_NAME_AS_VARIABLE

Constructor Detail

StateBackendOptions

public StateBackendOptions()