|Modifier and Type||Method and Description|
Creates a RECOVERED
CompletedCheckpointStore createRecoveredCompletedCheckpointStore(JobID jobId, int maxNumberOfCheckpointsToRetain, ClassLoader userClassLoader, SharedStateRegistryFactory sharedStateRegistryFactory, Executor ioExecutor) 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
userClassLoader- User code class loader of the job
sharedStateRegistryFactory- Simple factory to produce
ioExecutor- Executor used to run (async) deletes.
CompletedCheckpointStoreinstance for the job
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.