public class ZooKeeperCheckpointRecoveryFactory extends Object implements CheckpointRecoveryFactory
|Constructor and Description|
|Modifier and Type||Method and Description|
Creates a RECOVERED
public ZooKeeperCheckpointRecoveryFactory(org.apache.flink.shaded.curator5.org.apache.curator.framework.CuratorFramework client, Configuration config, Executor executor)
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.
jobID- Job ID to recover checkpoints for
CheckpointIDCounterinstance for the job
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.