org.apache.flink.runtime.checkpoint

Interface CheckpointStoreUtil

All Known Implementing Classes:

KubernetesCheckpointStoreUtil, ZooKeeperCheckpointStoreUtil

public interface CheckpointStoreUtil

CompletedCheckpointStore utility interfaces. For example, convert a name(e.g. ZooKeeper path, key name in Kubernetes ConfigMap) to checkpoint id in Long format, or vice versa.

Field Summary

Fields

Modifier and Type	Field and Description
static long	INVALID_CHECKPOINT_ID

Method Summary

Modifier and Type	Method and Description
String	checkpointIDToName(long checkpointId) Get the name in external storage from checkpoint id.
long	nameToCheckpointID(String name) Get the checkpoint id from name.

Field Detail

INVALID_CHECKPOINT_ID

static final long INVALID_CHECKPOINT_ID

See Also:

Constant Field Values

Method Detail

checkpointIDToName

String checkpointIDToName(long checkpointId)

Get the name in external storage from checkpoint id.

Parameters:

checkpointId - checkpoint id

Returns:

Key name in ConfigMap or child path name in ZooKeeper

nameToCheckpointID

long nameToCheckpointID(String name)

Get the checkpoint id from name.

Parameters:

name - Key name in ConfigMap or child path name in ZooKeeper

Returns:

parsed checkpoint id. Or INVALID_CHECKPOINT_ID when parsing failed.