Package 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 Description static ConfigOption<Boolean>
ENABLE_STATE_CHANGE_LOG
Whether to enable state change log.static ConfigOption<Integer>
MATERIALIZATION_MAX_FAILURES_ALLOWED
static ConfigOption<Boolean>
PERIODIC_MATERIALIZATION_ENABLED
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 Description StateChangelogOptions()
-
-
-
Field Detail
-
PERIODIC_MATERIALIZATION_ENABLED
public static final ConfigOption<Boolean> PERIODIC_MATERIALIZATION_ENABLED
-
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.
-
-