public class ZooKeeperCheckpointRecoveryFactory extends Object implements CheckpointRecoveryFactory
CheckpointCoordinator
components in RecoveryMode.ZOOKEEPER
.NUMBER_OF_SUCCESSFUL_CHECKPOINTS_TO_RETAIN
Constructor and Description |
---|
ZooKeeperCheckpointRecoveryFactory(org.apache.curator.framework.CuratorFramework client,
Configuration config) |
Modifier and Type | Method and Description |
---|---|
CheckpointIDCounter |
createCheckpointIDCounter(JobID jobID)
Creates a
CheckpointIDCounter instance for a job. |
CompletedCheckpointStore |
createCompletedCheckpoints(JobID jobId,
ClassLoader userClassLoader)
Creates a
CompletedCheckpointStore instance for a job. |
void |
start()
Starts the
CheckpointRecoveryFactory service. |
void |
stop()
Stops the
CheckpointRecoveryFactory service. |
public ZooKeeperCheckpointRecoveryFactory(org.apache.curator.framework.CuratorFramework client, Configuration config)
public void start()
CheckpointRecoveryFactory
CheckpointRecoveryFactory
service.start
in interface CheckpointRecoveryFactory
public void stop()
CheckpointRecoveryFactory
CheckpointRecoveryFactory
service.stop
in interface CheckpointRecoveryFactory
public CompletedCheckpointStore createCompletedCheckpoints(JobID jobId, ClassLoader userClassLoader) throws Exception
CheckpointRecoveryFactory
CompletedCheckpointStore
instance for a job.createCompletedCheckpoints
in interface CheckpointRecoveryFactory
jobId
- Job ID to recover checkpoints foruserClassLoader
- 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–2017 The Apache Software Foundation. All rights reserved.