Interface CheckpointRecoveryFactory
-
- All Known Implementing Classes:
KubernetesCheckpointRecoveryFactory
,PerJobCheckpointRecoveryFactory
,StandaloneCheckpointRecoveryFactory
,ZooKeeperCheckpointRecoveryFactory
public interface CheckpointRecoveryFactory
A factory for per Job checkpoint recovery components.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description CheckpointIDCounter
createCheckpointIDCounter(JobID jobId)
Creates aCheckpointIDCounter
instance for a job.CompletedCheckpointStore
createRecoveredCompletedCheckpointStore(JobID jobId, int maxNumberOfCheckpointsToRetain, SharedStateRegistryFactory sharedStateRegistryFactory, Executor ioExecutor, RecoveryClaimMode recoveryClaimMode)
Creates a RECOVEREDCompletedCheckpointStore
instance for a job.
-
-
-
Method Detail
-
createRecoveredCompletedCheckpointStore
CompletedCheckpointStore createRecoveredCompletedCheckpointStore(JobID jobId, int maxNumberOfCheckpointsToRetain, SharedStateRegistryFactory sharedStateRegistryFactory, Executor ioExecutor, RecoveryClaimMode recoveryClaimMode) throws Exception
Creates a RECOVEREDCompletedCheckpointStore
instance for a job. In this context, RECOVERED means, that if we already have completed checkpoints from previous runs, we should use them as the initial state.- Parameters:
jobId
- Job ID to recover checkpoints formaxNumberOfCheckpointsToRetain
- Maximum number of checkpoints to retainsharedStateRegistryFactory
- Simple factory to produceSharedStateRegistry
objects.ioExecutor
- Executor used to run (async) deletes.recoveryClaimMode
- the claim mode with which the job is restoring.- Returns:
CompletedCheckpointStore
instance for the job- Throws:
Exception
-
createCheckpointIDCounter
CheckpointIDCounter createCheckpointIDCounter(JobID jobId) throws Exception
Creates aCheckpointIDCounter
instance for a job.- Parameters:
jobId
- Job ID to recover checkpoints for- Returns:
CheckpointIDCounter
instance for the job- Throws:
Exception
-
-