public class StandaloneCheckpointRecoveryFactory extends Object implements CheckpointRecoveryFactory
CheckpointCoordinator
components in HighAvailabilityMode.NONE
.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 |
createCheckpointStore(JobID jobId,
int maxNumberOfCheckpointsToRetain,
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 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 ignored)
CheckpointRecoveryFactory
CheckpointIDCounter
instance for a job.createCheckpointIDCounter
in interface CheckpointRecoveryFactory
ignored
- Job ID to recover checkpoints forCheckpointIDCounter
instance for the jobCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.