org.apache.flink.runtime.state.filesystem

Class FsStateBackendFactory

java.lang.Object

org.apache.flink.runtime.state.filesystem.FsStateBackendFactory

All Implemented Interfaces:

StateBackendFactory<FsStateBackend>

public class FsStateBackendFactory
extends Object
implements StateBackendFactory<FsStateBackend>

A factory that creates an FsStateBackend from a configuration.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CHECKPOINT_DIRECTORY_URI_CONF_KEY The key under which the config stores the directory where checkpoints should be stored
static String	MEMORY_THRESHOLD_CONF_KEY The key under which the config stores the threshold for state to be store in memory, rather than in files

Constructor Summary

Constructors

Constructor and Description
FsStateBackendFactory()

Method Summary

Modifier and Type	Method and Description
FsStateBackend	createFromConfig(Configuration config) Creates the state backend, optionally using the given configuration.

Methods inherited from class java.lang.Object

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

Field Detail

CHECKPOINT_DIRECTORY_URI_CONF_KEY

public static final String CHECKPOINT_DIRECTORY_URI_CONF_KEY

The key under which the config stores the directory where checkpoints should be stored

See Also:

Constant Field Values

MEMORY_THRESHOLD_CONF_KEY

public static final String MEMORY_THRESHOLD_CONF_KEY

The key under which the config stores the threshold for state to be store in memory, rather than in files

See Also:

Constant Field Values

Constructor Detail

FsStateBackendFactory

public FsStateBackendFactory()

Method Detail

createFromConfig

public FsStateBackend createFromConfig(Configuration config)
                                throws Exception

Description copied from interface: StateBackendFactory

Creates the state backend, optionally using the given configuration.

Specified by:

createFromConfig in interface StateBackendFactory<FsStateBackend>

Parameters:

config - The Flink configuration (loaded by the TaskManager).

Returns:

The created state backend.

Throws:

Exception - Exceptions during instantiation can be forwarded.