org.apache.flink.runtime.state.memory

Class NonPersistentMetadataCheckpointStorageLocation

java.lang.Object

org.apache.flink.runtime.state.memory.MemCheckpointStreamFactory

org.apache.flink.runtime.state.memory.NonPersistentMetadataCheckpointStorageLocation

All Implemented Interfaces:

CheckpointStorageLocation, CheckpointStreamFactory

public class NonPersistentMetadataCheckpointStorageLocation
extends MemCheckpointStreamFactory
implements CheckpointStorageLocation

A checkpoint storage location for the MemoryStateBackend in case no durable persistence for metadata has been configured.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.runtime.state.memory.MemCheckpointStreamFactory

MemCheckpointStreamFactory.MemoryCheckpointOutputStream

Field Summary

Fields

Modifier and Type	Field and Description
static String	EXTERNAL_POINTER The external pointer returned for checkpoints that are not externally addressable.

Constructor Summary

Constructors

Constructor and Description
NonPersistentMetadataCheckpointStorageLocation(int maxStateSize)

Method Summary

Modifier and Type	Method and Description
CheckpointMetadataOutputStream	createMetadataOutputStream() Creates the output stream to persist the checkpoint metadata to.
void	disposeOnFailure() Disposes the checkpoint location in case the checkpoint has failed.
CheckpointStorageLocationReference	getLocationReference() Gets a reference to the storage location.

Methods inherited from class org.apache.flink.runtime.state.memory.MemCheckpointStreamFactory

canFastDuplicate, createCheckpointStateOutputStream, duplicate, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.runtime.state.CheckpointStreamFactory

canFastDuplicate, couldReuseStateHandle, createCheckpointStateOutputStream, duplicate, reusePreviousStateHandle

Field Detail

EXTERNAL_POINTER

public static final String EXTERNAL_POINTER

The external pointer returned for checkpoints that are not externally addressable.

See Also:

Constant Field Values

Constructor Detail

NonPersistentMetadataCheckpointStorageLocation

public NonPersistentMetadataCheckpointStorageLocation(int maxStateSize)

Method Detail

createMetadataOutputStream

public CheckpointMetadataOutputStream createMetadataOutputStream()
                                                          throws IOException

Description copied from interface: CheckpointStorageLocation

Creates the output stream to persist the checkpoint metadata to.

Specified by:

createMetadataOutputStream in interface CheckpointStorageLocation

Returns:

The output stream to persist the checkpoint metadata to.

Throws:

IOException - Thrown, if the stream cannot be opened due to an I/O error.

disposeOnFailure

public void disposeOnFailure()

Description copied from interface: CheckpointStorageLocation

Disposes the checkpoint location in case the checkpoint has failed. This method disposes all the data at that location, not just the data written by the particular node or process that calls this method.

Specified by:

disposeOnFailure in interface CheckpointStorageLocation

getLocationReference

public CheckpointStorageLocationReference getLocationReference()

Description copied from interface: CheckpointStorageLocation

Gets a reference to the storage location. This reference is sent to the target storage location via checkpoint RPC messages and checkpoint barriers, in a format avoiding backend-specific classes.

If there is no custom location information that needs to be communicated, this method can simply return CheckpointStorageLocationReference.getDefault().

Specified by:

getLocationReference in interface CheckpointStorageLocation