org.apache.flink.state.api.runtime

Class SavepointLoader

java.lang.Object

org.apache.flink.state.api.runtime.SavepointLoader

@Internal
public final class SavepointLoader
extends Object

Utility class for loading CheckpointMetadata metadata.

Method Summary

Modifier and Type	Method and Description
static CheckpointMetadata	loadSavepointMetadata(String savepointPath) Takes the given string (representing a pointer to a checkpoint) and resolves it to a file status for the checkpoint's metadata file.

Methods inherited from class java.lang.Object

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

Method Detail

loadSavepointMetadata

public static CheckpointMetadata loadSavepointMetadata(String savepointPath)
                                                throws IOException

Takes the given string (representing a pointer to a checkpoint) and resolves it to a file status for the checkpoint's metadata file.

This should only be used when the user code class loader is the current classloader for the thread.

Parameters:

savepointPath - The path to an external savepoint.

Returns:

A state handle to savepoint's metadata.

Throws:

IOException - Thrown, if the path cannot be resolved, the file system not accessed, or the path points to a location that does not seem to be a savepoint.