public class StandaloneCheckpointRecoveryFactory extends Object implements CheckpointRecoveryFactory
CheckpointCoordinator
components in RecoveryMode.STANDALONE
.NUMBER_OF_SUCCESSFUL_CHECKPOINTS_TO_RETAIN
Constructor and Description |
---|
StandaloneCheckpointRecoveryFactory() |
Modifier and Type | Method and Description |
---|---|
CheckpointIDCounter |
createCheckpointIDCounter(JobID ignored)
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 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 ignored)
CheckpointRecoveryFactory
CheckpointIDCounter
instance for a job.createCheckpointIDCounter
in interface CheckpointRecoveryFactory
ignored
- Job ID to recover checkpoints forCheckpointIDCounter
instance for the jobCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.