org.apache.flink.streaming.api.operators.sorted.state

Class BatchExecutionCheckpointStorage

java.lang.Object

org.apache.flink.streaming.api.operators.sorted.state.BatchExecutionCheckpointStorage

All Implemented Interfaces:

Serializable, CheckpointStorage

public class BatchExecutionCheckpointStorage
extends Object
implements CheckpointStorage

A simple CheckpointStorage which is used in a BATCH style execution.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BatchExecutionCheckpointStorage()

Method Summary

Modifier and Type	Method and Description
CheckpointStorageAccess	createCheckpointStorage(JobID jobId) Creates a storage for checkpoints for the given job.
CompletedCheckpointStorageLocation	resolveCheckpoint(String externalPointer) Resolves the given pointer to a checkpoint/savepoint into a checkpoint location.

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchExecutionCheckpointStorage

public BatchExecutionCheckpointStorage()

Method Detail

resolveCheckpoint

public CompletedCheckpointStorageLocation resolveCheckpoint(String externalPointer)

Description copied from interface: CheckpointStorage

Resolves the given pointer to a checkpoint/savepoint into a checkpoint location. The location supports reading the checkpoint metadata, or disposing the checkpoint storage location.

Specified by:

resolveCheckpoint in interface CheckpointStorage

Parameters:

externalPointer - The external checkpoint pointer to resolve.

Returns:

The checkpoint location handle.

createCheckpointStorage

public CheckpointStorageAccess createCheckpointStorage(JobID jobId)

Description copied from interface: CheckpointStorage

Creates a storage for checkpoints for the given job. The checkpoint storage is used to write checkpoint data and metadata.

Specified by:

createCheckpointStorage in interface CheckpointStorage

Parameters:

jobId - The job to store checkpoint data for.

Returns:

A checkpoint storage for the given job.