org.apache.flink.runtime.state

Interface StateBackendFactory<T extends AbstractStateBackend>

Type Parameters:

T - The type of the state backend created.

All Known Implementing Classes:

FsStateBackendFactory

public interface StateBackendFactory<T extends AbstractStateBackend>

A factory to create a specific state backend. The state backend creation gets a Configuration object that can be used to read further config values.

Method Summary

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

Method Detail

createFromConfig

AbstractStateBackend createFromConfig(Configuration config)
                               throws Exception

Creates the state backend, optionally using the given configuration.

Parameters:

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

Returns:

The created state backend.

Throws:

Exception - Exceptions during instantiation can be forwarded.