public class ZooKeeperCheckpointRecoveryFactory extends Object implements CheckpointRecoveryFactory
CheckpointCoordinator
components in HighAvailabilityMode.ZOOKEEPER
.Constructor and Description |
---|
ZooKeeperCheckpointRecoveryFactory(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client,
Configuration config,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
CheckpointIDCounter |
createCheckpointIDCounter(JobID jobID)
Creates a
CheckpointIDCounter instance for a job. |
CompletedCheckpointStore |
createCheckpointStore(JobID jobId,
int maxNumberOfCheckpointsToRetain,
ClassLoader userClassLoader)
Creates a
CompletedCheckpointStore instance for a job. |
public ZooKeeperCheckpointRecoveryFactory(org.apache.flink.shaded.curator4.org.apache.curator.framework.CuratorFramework client, Configuration config, Executor executor)
public CompletedCheckpointStore createCheckpointStore(JobID jobId, int maxNumberOfCheckpointsToRetain, ClassLoader userClassLoader) throws Exception
CheckpointRecoveryFactory
CompletedCheckpointStore
instance for a job.createCheckpointStore
in interface CheckpointRecoveryFactory
jobId
- Job ID to recover checkpoints formaxNumberOfCheckpointsToRetain
- Maximum number of checkpoints to retainuserClassLoader
- User code class loader of the jobCompletedCheckpointStore
instance for the jobException
public CheckpointIDCounter createCheckpointIDCounter(JobID jobID) throws Exception
CheckpointRecoveryFactory
CheckpointIDCounter
instance for a job.createCheckpointIDCounter
in interface CheckpointRecoveryFactory
jobID
- Job ID to recover checkpoints forCheckpointIDCounter
instance for the jobException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.