Modifier and Type | Class and Description |
---|---|
class |
RocksDBStateBackend
A State Backend that stores its state in
RocksDB . |
Modifier and Type | Method and Description |
---|---|
void |
ExecutionGraph.enableCheckpointing(long interval,
long checkpointTimeout,
long minPauseBetweenCheckpoints,
int maxConcurrentCheckpoints,
ExternalizedCheckpointSettings externalizeSettings,
List<ExecutionJobVertex> verticesToTrigger,
List<ExecutionJobVertex> verticesToWaitFor,
List<ExecutionJobVertex> verticesToCommitTo,
List<MasterTriggerRestoreHook<?>> masterHooks,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
String checkpointDir,
StateBackend metadataStore,
CheckpointStatsTracker statsTracker) |
Modifier and Type | Method and Description |
---|---|
SerializedValue<StateBackend> |
JobCheckpointingSettings.getDefaultStateBackend() |
Constructor and Description |
---|
JobCheckpointingSettings(List<JobVertexID> verticesToTrigger,
List<JobVertexID> verticesToAcknowledge,
List<JobVertexID> verticesToConfirm,
long checkpointInterval,
long checkpointTimeout,
long minPauseBetweenCheckpoints,
int maxConcurrentCheckpoints,
ExternalizedCheckpointSettings externalizedCheckpointSettings,
SerializedValue<StateBackend> defaultStateBackend,
boolean isExactlyOnce) |
JobCheckpointingSettings(List<JobVertexID> verticesToTrigger,
List<JobVertexID> verticesToAcknowledge,
List<JobVertexID> verticesToConfirm,
long checkpointInterval,
long checkpointTimeout,
long minPauseBetweenCheckpoints,
int maxConcurrentCheckpoints,
ExternalizedCheckpointSettings externalizedCheckpointSettings,
SerializedValue<StateBackend> defaultStateBackend,
SerializedValue<MasterTriggerRestoreHook.Factory[]> masterHooks,
boolean isExactlyOnce) |
Modifier and Type | Interface and Description |
---|---|
interface |
StateBackendFactory<T extends StateBackend>
A factory to create a specific state backend.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractStateBackend
An abstract base implementation of the
StateBackend interface. |
Modifier and Type | Method and Description |
---|---|
static StateBackend |
AbstractStateBackend.loadStateBackendFromConfig(Configuration config,
ClassLoader classLoader,
org.slf4j.Logger logger)
Loads the state backend from the configuration, from the parameter 'state.backend', as defined
in
CoreOptions.STATE_BACKEND . |
static StateBackend |
AbstractStateBackend.loadStateBackendFromConfigOrCreateDefault(Configuration config,
ClassLoader classLoader,
org.slf4j.Logger logger)
Loads the state backend from the configuration, from the parameter 'state.backend', as defined
in
CoreOptions.STATE_BACKEND . |
Modifier and Type | Class and Description |
---|---|
class |
FsStateBackend
The file state backend is a state backend that stores the state of streaming jobs in a file system.
|
Modifier and Type | Class and Description |
---|---|
class |
MemoryStateBackend
A
AbstractStateBackend that stores all its data and checkpoints in memory and has no
capabilities to spill to disk. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.