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 Savepoint metadata.

Method Summary

Modifier and Type	Method and Description
static Savepoint	loadSavepoint(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

loadSavepoint

public static Savepoint loadSavepoint(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.