org.apache.flink.runtime.persistence.filesystem

Class FileSystemStateStorageHelper<T extends Serializable>

java.lang.Object

org.apache.flink.runtime.persistence.filesystem.FileSystemStateStorageHelper<T>

Type Parameters:

T - The type of the data that can be stored by this storage helper.

All Implemented Interfaces:

RetrievableStateStorageHelper<T>

public class FileSystemStateStorageHelper<T extends Serializable>
extends Object
implements RetrievableStateStorageHelper<T>

RetrievableStateStorageHelper implementation which stores the state in the given filesystem path.

Constructor Summary

Constructors

Constructor and Description
FileSystemStateStorageHelper(Path rootPath, String prefix)

Method Summary

Modifier and Type	Method and Description
RetrievableStateHandle<T>	store(T state) Stores the given state and returns a state handle to it.

Methods inherited from class java.lang.Object

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

Constructor Detail

FileSystemStateStorageHelper

public FileSystemStateStorageHelper(Path rootPath,
                                    String prefix)
                             throws IOException

Throws:

IOException

Method Detail

store

public RetrievableStateHandle<T> store(T state)
                                throws Exception

Description copied from interface: RetrievableStateStorageHelper

Stores the given state and returns a state handle to it.

Specified by:

store in interface RetrievableStateStorageHelper<T extends Serializable>

Parameters:

state - State to be stored

Returns:

State handle to the stored state

Throws:

Exception - if an error occurred while storing the state.