Package 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	Description
StandaloneCheckpointRecoveryFactory()

Method Summary

Modifier and Type	Method	Description
CheckpointIDCounter	createCheckpointIDCounter(JobID ignored)	Creates a CheckpointIDCounter instance for a job.
CompletedCheckpointStore	createRecoveredCompletedCheckpointStore(JobID jobId, int maxNumberOfCheckpointsToRetain, SharedStateRegistryFactory sharedStateRegistryFactory, Executor ioExecutor, RecoveryClaimMode recoveryClaimMode)	Creates a RECOVERED 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

createRecoveredCompletedCheckpointStore

public CompletedCheckpointStore createRecoveredCompletedCheckpointStore(JobID jobId,
                                                                        int maxNumberOfCheckpointsToRetain,
                                                                        SharedStateRegistryFactory sharedStateRegistryFactory,
                                                                        Executor ioExecutor,
                                                                        RecoveryClaimMode recoveryClaimMode)
                                                                 throws Exception

Description copied from interface: CheckpointRecoveryFactory

Creates a RECOVERED CompletedCheckpointStore instance for a job. In this context, RECOVERED means, that if we already have completed checkpoints from previous runs, we should use them as the initial state.

Specified by:

createRecoveredCompletedCheckpointStore in interface CheckpointRecoveryFactory

Parameters:

jobId - Job ID to recover checkpoints for

maxNumberOfCheckpointsToRetain - Maximum number of checkpoints to retain

sharedStateRegistryFactory - Simple factory to produce SharedStateRegistry objects.

ioExecutor - Executor used to run (async) deletes.

recoveryClaimMode - the claim mode with which the job is restoring.

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