org.apache.flink.runtime.checkpoint

Interface CheckpointRecoveryFactory

All Known Implementing Classes:

StandaloneCheckpointRecoveryFactory, ZooKeeperCheckpointRecoveryFactory

public interface CheckpointRecoveryFactory

A factory for per Job checkpoint recovery components.

Field Summary

Fields

Modifier and Type	Field and Description
static int	NUMBER_OF_SUCCESSFUL_CHECKPOINTS_TO_RETAIN The number of CompletedCheckpoint instances to retain.

Method Summary

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.

Field Detail

NUMBER_OF_SUCCESSFUL_CHECKPOINTS_TO_RETAIN

static final int NUMBER_OF_SUCCESSFUL_CHECKPOINTS_TO_RETAIN

The number of CompletedCheckpoint instances to retain.

See Also:

Constant Field Values

Method Detail

start

void start()

Starts the CheckpointRecoveryFactory service.

stop

void stop()

Stops the CheckpointRecoveryFactory service.

createCompletedCheckpoints

CompletedCheckpointStore createCompletedCheckpoints(JobID jobId,
                                                    ClassLoader userClassLoader)
                                             throws Exception

Creates a CompletedCheckpointStore instance for a job.

Parameters:

jobId - Job ID to recover checkpoints for

userClassLoader - User code class loader of the job

Returns:

CompletedCheckpointStore instance for the job

Throws:

Exception

createCheckpointIDCounter

CheckpointIDCounter createCheckpointIDCounter(JobID jobId)
                                       throws Exception

Creates a CheckpointIDCounter instance for a job.

Parameters:

jobId - Job ID to recover checkpoints for

Returns:

CheckpointIDCounter instance for the job

Throws:

Exception