org.apache.flink.runtime.state.filesystem

Class FsStateBackendFactory

java.lang.Object

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

All Implemented Interfaces:

StateBackendFactory<FsStateBackend>

@PublicEvolving
public class FsStateBackendFactory
extends Object
implements StateBackendFactory<FsStateBackend>

A factory that creates an FsStateBackend from a configuration.

Constructor Summary

Constructors

Constructor and Description
FsStateBackendFactory()

Method Summary

Modifier and Type	Method and Description
FsStateBackend	createFromConfig(Configuration config, ClassLoader classLoader) 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

Constructor Detail

FsStateBackendFactory

public FsStateBackendFactory()

Method Detail

createFromConfig

public FsStateBackend createFromConfig(Configuration config,
                                       ClassLoader classLoader)
                                throws IllegalConfigurationException

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).

classLoader - The class loader that should be used to load the state backend.

Returns:

The created state backend.

Throws:

IllegalConfigurationException - If the configuration misses critical values, or specifies invalid values