Modifier and Type | Method and Description |
---|---|
CompletedCheckpointStore |
KubernetesCheckpointRecoveryFactory.createRecoveredCompletedCheckpointStore(JobID jobID,
int maxNumberOfCheckpointsToRetain,
SharedStateRegistryFactory sharedStateRegistryFactory,
Executor ioExecutor,
RestoreMode restoreMode) |
Modifier and Type | Method and Description |
---|---|
static CompletedCheckpointStore |
KubernetesUtils.createCompletedCheckpointStore(Configuration configuration,
FlinkKubeClient kubeClient,
Executor executor,
String configMapName,
String lockIdentity,
int maxNumberOfCheckpointsToRetain,
SharedStateRegistryFactory sharedStateRegistryFactory,
Executor ioExecutor,
RestoreMode restoreMode)
Create a
DefaultCompletedCheckpointStore with KubernetesStateHandleStore . |
Modifier and Type | Class and Description |
---|---|
class |
PerJobCheckpointRecoveryFactory<T extends CompletedCheckpointStore>
Simple
CheckpointRecoveryFactory which creates and keeps separate CompletedCheckpointStore and CheckpointIDCounter for each JobID . |
static interface |
PerJobCheckpointRecoveryFactory.CheckpointStoreRecoveryHelper<StoreType extends CompletedCheckpointStore>
Restores or creates a
CompletedCheckpointStore , optionally using an existing one. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCompleteCheckpointStore
The abstract class of
CompletedCheckpointStore , which holds the SharedStateRegistry and provides the registration of shared state. |
class |
DeactivatedCheckpointCompletedCheckpointStore
This class represents a
CompletedCheckpointStore if checkpointing has been disabled. |
class |
DefaultCompletedCheckpointStore<R extends ResourceVersion<R>>
Default implementation of
CompletedCheckpointStore . |
class |
EmbeddedCompletedCheckpointStore
An embedded in-memory checkpoint store, which supports shutdown and suspend.
|
class |
StandaloneCompletedCheckpointStore
CompletedCheckpointStore for JobManagers running in HighAvailabilityMode.NONE . |
Modifier and Type | Method and Description |
---|---|
static <T extends CompletedCheckpointStore> |
PerJobCheckpointRecoveryFactory.withoutCheckpointStoreRecovery(java.util.function.IntFunction<T> storeFn) |
Modifier and Type | Method and Description |
---|---|
CompletedCheckpointStore |
CheckpointRecoveryFactory.createRecoveredCompletedCheckpointStore(JobID jobId,
int maxNumberOfCheckpointsToRetain,
SharedStateRegistryFactory sharedStateRegistryFactory,
Executor ioExecutor,
RestoreMode restoreMode)
Creates a RECOVERED
CompletedCheckpointStore instance for a job. |
CompletedCheckpointStore |
PerJobCheckpointRecoveryFactory.createRecoveredCompletedCheckpointStore(JobID jobId,
int maxNumberOfCheckpointsToRetain,
SharedStateRegistryFactory sharedStateRegistryFactory,
Executor ioExecutor,
RestoreMode restoreMode) |
CompletedCheckpointStore |
ZooKeeperCheckpointRecoveryFactory.createRecoveredCompletedCheckpointStore(JobID jobId,
int maxNumberOfCheckpointsToRetain,
SharedStateRegistryFactory sharedStateRegistryFactory,
Executor ioExecutor,
RestoreMode restoreMode) |
CompletedCheckpointStore |
StandaloneCheckpointRecoveryFactory.createRecoveredCompletedCheckpointStore(JobID jobId,
int maxNumberOfCheckpointsToRetain,
SharedStateRegistryFactory sharedStateRegistryFactory,
Executor ioExecutor,
RestoreMode restoreMode) |
CompletedCheckpointStore |
CheckpointCoordinator.getCheckpointStore() |
Modifier and Type | Method and Description |
---|---|
static DefaultExecutionGraph |
DefaultExecutionGraphBuilder.buildGraph(JobGraph jobGraph,
Configuration jobManagerConfig,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
ClassLoader classLoader,
CompletedCheckpointStore completedCheckpointStore,
CheckpointsCleaner checkpointsCleaner,
CheckpointIDCounter checkpointIdCounter,
Time rpcTimeout,
BlobWriter blobWriter,
org.slf4j.Logger log,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker,
TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionLocationConstraint,
ExecutionDeploymentListener executionDeploymentListener,
ExecutionStateUpdateListener executionStateUpdateListener,
long initializationTimestamp,
VertexAttemptNumberStore vertexAttemptNumberStore,
VertexParallelismStore vertexParallelismStore,
java.util.function.Supplier<CheckpointStatsTracker> checkpointStatsTrackerFactory,
boolean isDynamicGraph,
ExecutionJobVertex.Factory executionJobVertexFactory) |
void |
DefaultExecutionGraph.enableCheckpointing(CheckpointCoordinatorConfiguration chkConfig,
List<MasterTriggerRestoreHook<?>> masterHooks,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
StateBackend checkpointStateBackend,
CheckpointStorage checkpointStorage,
CheckpointStatsTracker statsTracker,
CheckpointsCleaner checkpointsCleaner,
String changelogStorageName) |
void |
ExecutionGraph.enableCheckpointing(CheckpointCoordinatorConfiguration chkConfig,
List<MasterTriggerRestoreHook<?>> masterHooks,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
StateBackend checkpointStateBackend,
CheckpointStorage checkpointStorage,
CheckpointStatsTracker statsTracker,
CheckpointsCleaner checkpointsCleaner,
String changelogStorage) |
Modifier and Type | Method and Description |
---|---|
static CompletedCheckpointStore |
SchedulerUtils.createCompletedCheckpointStoreIfCheckpointingIsEnabled(JobGraph jobGraph,
Configuration configuration,
CheckpointRecoveryFactory checkpointRecoveryFactory,
Executor ioExecutor,
org.slf4j.Logger log) |
Modifier and Type | Method and Description |
---|---|
ExecutionGraph |
DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(JobGraph jobGraph,
CompletedCheckpointStore completedCheckpointStore,
CheckpointsCleaner checkpointsCleaner,
CheckpointIDCounter checkpointIdCounter,
TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionLocationConstraint,
long initializationTimestamp,
VertexAttemptNumberStore vertexAttemptNumberStore,
VertexParallelismStore vertexParallelismStore,
ExecutionStateUpdateListener executionStateUpdateListener,
org.slf4j.Logger log) |
ExecutionGraph |
ExecutionGraphFactory.createAndRestoreExecutionGraph(JobGraph jobGraph,
CompletedCheckpointStore completedCheckpointStore,
CheckpointsCleaner checkpointsCleaner,
CheckpointIDCounter checkpointIdCounter,
TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionLocationConstraint,
long initializationTimestamp,
VertexAttemptNumberStore vertexAttemptNumberStore,
VertexParallelismStore vertexParallelismStore,
ExecutionStateUpdateListener executionStateUpdateListener,
org.slf4j.Logger log)
Create and restore
ExecutionGraph from the given JobGraph and services. |
Modifier and Type | Method and Description |
---|---|
static CompletedCheckpointStore |
ZooKeeperUtils.createCompletedCheckpoints(org.apache.flink.shaded.curator5.org.apache.curator.framework.CuratorFramework client,
Configuration configuration,
int maxNumberOfCheckpointsToRetain,
SharedStateRegistryFactory sharedStateRegistryFactory,
Executor ioExecutor,
Executor executor,
RestoreMode restoreMode)
Creates a
DefaultCompletedCheckpointStore instance with ZooKeeperStateHandleStore . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.