org.apache.flink.runtime.checkpoint

Class StandaloneCheckpointRecoveryFactory

java.lang.Object

org.apache.flink.runtime.checkpoint.StandaloneCheckpointRecoveryFactory

All Implemented Interfaces:

CheckpointRecoveryFactory

public class StandaloneCheckpointRecoveryFactory
extends Object
implements CheckpointRecoveryFactory

CheckpointCoordinator components in HighAvailabilityMode.NONE.

Constructor Summary

Constructors

Constructor and Description
StandaloneCheckpointRecoveryFactory()

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StandaloneCheckpointRecoveryFactory

public StandaloneCheckpointRecoveryFactory()

Method Detail

createCheckpointStore

public CompletedCheckpointStore createCheckpointStore(JobID jobId,
                                                      int maxNumberOfCheckpointsToRetain,
                                                      ClassLoader userClassLoader)
                                               throws Exception

Description copied from interface: CheckpointRecoveryFactory

Creates a CompletedCheckpointStore instance for a job.

Specified by:

createCheckpointStore in interface CheckpointRecoveryFactory

Parameters:

jobId - Job ID to recover checkpoints for

maxNumberOfCheckpointsToRetain - Maximum number of checkpoints to retain

userClassLoader - User code class loader of the job

Returns:

CompletedCheckpointStore instance for the job

Throws:

Exception

createCheckpointIDCounter

public CheckpointIDCounter createCheckpointIDCounter(JobID ignored)

Description copied from interface: CheckpointRecoveryFactory

Creates a CheckpointIDCounter instance for a job.

Specified by:

createCheckpointIDCounter in interface CheckpointRecoveryFactory

Parameters:

ignored - Job ID to recover checkpoints for

Returns:

CheckpointIDCounter instance for the job