|Constructor and Description|
|Modifier and Type||Method and Description|
Creates a RECOVERED
public CompletedCheckpointStore createRecoveredCompletedCheckpointStore(JobID jobId, int maxNumberOfCheckpointsToRetain, SharedStateRegistryFactory sharedStateRegistryFactory, Executor ioExecutor, RestoreMode restoreMode) throws Exception
CompletedCheckpointStoreinstance 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 for
maxNumberOfCheckpointsToRetain- Maximum number of checkpoints to retain
sharedStateRegistryFactory- Simple factory to produce
ioExecutor- Executor used to run (async) deletes.
restoreMode- the restore mode with which the job is restoring.
CompletedCheckpointStoreinstance for the job
public CheckpointIDCounter createCheckpointIDCounter(JobID jobID) throws Exception
CheckpointIDCounterinstance for a job.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.