Constructor and Description |
---|
EmbeddedRocksDBStateBackend(TernaryBoolean enableIncrementalCheckpointing)
Creates a new
EmbeddedRocksDBStateBackend for storing local state. |
RocksDBStateBackend(StateBackend checkpointStreamBackend,
TernaryBoolean enableIncrementalCheckpointing)
Deprecated.
Creates a new
RocksDBStateBackend that uses the given state backend to store its
checkpoint data streams. |
Modifier and Type | Method and Description |
---|---|
TernaryBoolean |
AccessExecutionGraph.isChangelogStateBackendEnabled()
Returns whether the state changelog is enabled for this ExecutionGraph.
|
TernaryBoolean |
DefaultExecutionGraph.isChangelogStateBackendEnabled() |
TernaryBoolean |
ArchivedExecutionGraph.isChangelogStateBackendEnabled() |
Constructor and Description |
---|
ArchivedExecutionGraph(JobID jobID,
String jobName,
Map<JobVertexID,ArchivedExecutionJobVertex> tasks,
List<ArchivedExecutionJobVertex> verticesInCreationOrder,
long[] stateTimestamps,
JobStatus state,
ErrorInfo failureCause,
String jsonPlan,
StringifiedAccumulatorResult[] archivedUserAccumulators,
Map<String,SerializedValue<OptionalFailure<Object>>> serializedUserAccumulators,
ArchivedExecutionConfig executionConfig,
boolean isStoppable,
CheckpointCoordinatorConfiguration jobCheckpointingConfiguration,
CheckpointStatsSnapshot checkpointStatsSnapshot,
String stateBackendName,
String checkpointStorageName,
TernaryBoolean stateChangelogEnabled,
String changelogStorageName) |
Modifier and Type | Method and Description |
---|---|
void |
JobGraph.setChangelogStateBackendEnabled(TernaryBoolean changelogStateBackendEnabled) |
Modifier and Type | Method and Description |
---|---|
TernaryBoolean |
JobCheckpointingSettings.isChangelogStateBackendEnabled() |
Constructor and Description |
---|
JobCheckpointingSettings(CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration,
SerializedValue<StateBackend> defaultStateBackend,
TernaryBoolean changelogStateBackendEnabled,
SerializedValue<CheckpointStorage> defaultCheckpointStorage,
SerializedValue<MasterTriggerRestoreHook.Factory[]> masterHooks) |
Modifier and Type | Method and Description |
---|---|
static StateBackend |
StateBackendLoader.fromApplicationOrConfigOrDefault(StateBackend fromApplication,
TernaryBoolean isChangelogStateBackendEnableFromApplication,
Configuration config,
ClassLoader classLoader,
org.slf4j.Logger logger)
This is the state backend loader that loads a
DelegatingStateBackend wrapping the
state backend loaded from StateBackendLoader.loadFromApplicationOrConfigOrDefaultInternal(org.apache.flink.runtime.state.StateBackend, org.apache.flink.configuration.Configuration, java.lang.ClassLoader, org.slf4j.Logger) when delegation is enabled. |
Constructor and Description |
---|
FsStateBackend(URI checkpointDirectory,
URI defaultSavepointDirectory,
int fileStateSizeThreshold,
int writeBufferSize,
TernaryBoolean asynchronousSnapshots)
Deprecated.
Creates a new state backend that stores its checkpoint data in the file system and location
defined by the given URI.
|
Constructor and Description |
---|
MemoryStateBackend(String checkpointPath,
String savepointPath,
int maxStateSize,
TernaryBoolean asynchronousSnapshots)
Deprecated.
Creates a new MemoryStateBackend, setting optionally the paths to persist checkpoint metadata
and savepoints to, as well as configuring state thresholds and asynchronous operations.
|
Modifier and Type | Method and Description |
---|---|
TernaryBoolean |
StreamExecutionEnvironment.isChangelogStateBackendEnabled()
Gets the enable status of change log for state backend.
|
Modifier and Type | Method and Description |
---|---|
TernaryBoolean |
StreamGraph.isChangelogStateBackendEnabled() |
TernaryBoolean |
StreamConfig.isChangelogStateBackendEnabled(ClassLoader cl) |
Modifier and Type | Method and Description |
---|---|
void |
StreamGraph.setChangelogStateBackendEnabled(TernaryBoolean changelogStateBackendEnabled) |
StreamGraphGenerator |
StreamGraphGenerator.setChangelogStateBackendEnabled(TernaryBoolean changelogStateBackendEnabled) |
void |
StreamConfig.setChangelogStateBackendEnabled(TernaryBoolean enabled) |
Modifier and Type | Method and Description |
---|---|
static TernaryBoolean |
TernaryBoolean.fromBoolean(boolean bool)
|
static TernaryBoolean |
TernaryBoolean.fromBoxedBoolean(Boolean bool)
Converts the given boxed Boolean to a TernaryBoolean.
|
TernaryBoolean |
TernaryBoolean.resolveUndefined(boolean valueForUndefined)
Gets the boolean value corresponding to this value.
|
static TernaryBoolean |
TernaryBoolean.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static TernaryBoolean[] |
TernaryBoolean.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.