Modifier and Type | Method and Description |
---|---|
CompletedCheckpointStore |
KubernetesCheckpointRecoveryFactory.createCheckpointStore(JobID jobID,
int maxNumberOfCheckpointsToRetain,
ClassLoader userClassLoader) |
Modifier and Type | Method and Description |
---|---|
static CompletedCheckpointStore |
KubernetesUtils.createCompletedCheckpointStore(Configuration configuration,
FlinkKubeClient kubeClient,
Executor executor,
String configMapName,
String lockIdentity,
int maxNumberOfCheckpointsToRetain)
Create a
DefaultCompletedCheckpointStore with KubernetesStateHandleStore . |
Modifier and Type | Class and Description |
---|---|
class |
DeactivatedCheckpointCompletedCheckpointStore
This class represents a
CompletedCheckpointStore if checkpointing has been enabled. |
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 |
---|---|
CompletedCheckpointStore |
CheckpointRecoveryFactory.createCheckpointStore(JobID jobId,
int maxNumberOfCheckpointsToRetain,
ClassLoader userClassLoader)
Creates a
CompletedCheckpointStore instance for a job. |
CompletedCheckpointStore |
StandaloneCheckpointRecoveryFactory.createCheckpointStore(JobID jobId,
int maxNumberOfCheckpointsToRetain,
ClassLoader userClassLoader) |
CompletedCheckpointStore |
PerJobCheckpointRecoveryFactory.createCheckpointStore(JobID jobId,
int maxNumberOfCheckpointsToRetain,
ClassLoader userClassLoader) |
CompletedCheckpointStore |
ZooKeeperCheckpointRecoveryFactory.createCheckpointStore(JobID jobId,
int maxNumberOfCheckpointsToRetain,
ClassLoader userClassLoader) |
CompletedCheckpointStore |
CheckpointCoordinator.getCheckpointStore() |
static CompletedCheckpointStore |
CompletedCheckpointStore.storeFor(Runnable postCleanupAction,
CompletedCheckpoint... checkpoints) |
Modifier and Type | Method and Description |
---|---|
static CheckpointRecoveryFactory |
PerJobCheckpointRecoveryFactory.useSameServicesForAllJobs(CompletedCheckpointStore store,
CheckpointIDCounter counter) |
Constructor and Description |
---|
PerJobCheckpointRecoveryFactory(java.util.function.Function<Integer,CompletedCheckpointStore> completedCheckpointStorePerJobFactory,
java.util.function.Supplier<CheckpointIDCounter> checkpointIDCounterPerJobFactory) |
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,
MetricGroup metrics,
BlobWriter blobWriter,
org.slf4j.Logger log,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker,
TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionLocationConstraint,
ExecutionDeploymentListener executionDeploymentListener,
ExecutionStateUpdateListener executionStateUpdateListener,
long initializationTimestamp,
VertexAttemptNumberStore vertexAttemptNumberStore,
VertexParallelismStore vertexParallelismStore) |
void |
DefaultExecutionGraph.enableCheckpointing(CheckpointCoordinatorConfiguration chkConfig,
List<MasterTriggerRestoreHook<?>> masterHooks,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
StateBackend checkpointStateBackend,
CheckpointStorage checkpointStorage,
CheckpointStatsTracker statsTracker,
CheckpointsCleaner checkpointsCleaner) |
void |
ExecutionGraph.enableCheckpointing(CheckpointCoordinatorConfiguration chkConfig,
List<MasterTriggerRestoreHook<?>> masterHooks,
CheckpointIDCounter checkpointIDCounter,
CompletedCheckpointStore checkpointStore,
StateBackend checkpointStateBackend,
CheckpointStorage checkpointStorage,
CheckpointStatsTracker statsTracker,
CheckpointsCleaner checkpointsCleaner) |
Modifier and Type | Method and Description |
---|---|
static CompletedCheckpointStore |
SchedulerUtils.createCompletedCheckpointStoreIfCheckpointingIsEnabled(JobGraph jobGraph,
Configuration configuration,
ClassLoader userCodeLoader,
CheckpointRecoveryFactory checkpointRecoveryFactory,
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,
org.slf4j.Logger log) |
ExecutionGraph |
ExecutionGraphFactory.createAndRestoreExecutionGraph(JobGraph jobGraph,
CompletedCheckpointStore completedCheckpointStore,
CheckpointsCleaner checkpointsCleaner,
CheckpointIDCounter checkpointIdCounter,
TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionLocationConstraint,
long initializationTimestamp,
VertexAttemptNumberStore vertexAttemptNumberStore,
VertexParallelismStore vertexParallelismStore,
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.curator4.org.apache.curator.framework.CuratorFramework client,
Configuration configuration,
JobID jobId,
int maxNumberOfCheckpointsToRetain,
Executor executor)
Creates a
DefaultCompletedCheckpointStore instance with ZooKeeperStateHandleStore . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.