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,
SharedStateRegistryFactory sharedStateRegistryFactory,
Executor ioExecutor,
RestoreMode restoreMode)
Creates a RECOVERED
CompletedCheckpointStore instance for a job. |
CompletedCheckpointStore createRecoveredCompletedCheckpointStore(JobID jobId, int maxNumberOfCheckpointsToRetain, SharedStateRegistryFactory sharedStateRegistryFactory, Executor ioExecutor, RestoreMode restoreMode) 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 retainsharedStateRegistryFactory
- Simple factory to produce SharedStateRegistry
objects.ioExecutor
- Executor used to run (async) deletes.restoreMode
- the restore mode with which the job is restoring.CompletedCheckpointStore
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–2024 The Apache Software Foundation. All rights reserved.