org.apache.flink.configuration

Class StateChangelogOptions

java.lang.Object

org.apache.flink.configuration.StateChangelogOptions

@PublicEvolving
public class StateChangelogOptions
extends Object

A collection of all configuration options that relate to changelog.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<Boolean>	ENABLE_STATE_CHANGE_LOG Whether to enable state change log.
static ConfigOption<Integer>	MATERIALIZATION_MAX_FAILURES_ALLOWED
static ConfigOption<Duration>	PERIODIC_MATERIALIZATION_INTERVAL
static ConfigOption<String>	STATE_CHANGE_LOG_STORAGE Which storage to use to store state changelog.

Constructor Summary

Constructors

Constructor and Description
StateChangelogOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

PERIODIC_MATERIALIZATION_INTERVAL

public static final ConfigOption<Duration> PERIODIC_MATERIALIZATION_INTERVAL

MATERIALIZATION_MAX_FAILURES_ALLOWED

public static final ConfigOption<Integer> MATERIALIZATION_MAX_FAILURES_ALLOWED

ENABLE_STATE_CHANGE_LOG

public static final ConfigOption<Boolean> ENABLE_STATE_CHANGE_LOG

Whether to enable state change log.

STATE_CHANGE_LOG_STORAGE

public static final ConfigOption<String> STATE_CHANGE_LOG_STORAGE

Which storage to use to store state changelog.

Recognized shortcut name is 'memory' from InMemoryStateChangelogStorageFactory.getIdentifier(), which is also the default value.

Constructor Detail

StateChangelogOptions

public StateChangelogOptions()