public interface CheckpointRecoveryFactory
Modifier and Type | Method and Description |
---|---|
CheckpointIDCounter |
createCheckpointIDCounter(JobID jobId)
Creates a
CheckpointIDCounter instance for a job. |
CompletedCheckpointStore |
createRecoveredCompletedCheckpointStore(JobID jobId,
int maxNumberOfCheckpointsToRetain,
ClassLoader userClassLoader)
Creates a RECOVERED
CompletedCheckpointStore instance for a job. |
CompletedCheckpointStore createRecoveredCompletedCheckpointStore(JobID jobId, int maxNumberOfCheckpointsToRetain, ClassLoader userClassLoader) throws Exception
CompletedCheckpointStore
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.jobId
- Job ID to recover checkpoints formaxNumberOfCheckpointsToRetain
- Maximum number of checkpoints to retainuserClassLoader
- User code class loader of the jobCompletedCheckpointStore
instance for the jobException
CheckpointIDCounter createCheckpointIDCounter(JobID jobId) throws Exception
CheckpointIDCounter
instance for a job.jobId
- Job ID to recover checkpoints forCheckpointIDCounter
instance for the jobException
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.