org.apache.flink.state.forst

Class ForStStateBackendFactory

java.lang.Object

org.apache.flink.state.forst.ForStStateBackendFactory

All Implemented Interfaces:

StateBackendFactory<ForStStateBackend>

@Experimental
public class ForStStateBackendFactory
extends Object
implements StateBackendFactory<ForStStateBackend>

A factory that creates an ForStStateBackend from a configuration.

Constructor Summary

Constructors

Constructor and Description
ForStStateBackendFactory()

Method Summary

Modifier and Type	Method and Description
ForStStateBackend	createFromConfig(ReadableConfig 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

ForStStateBackendFactory

public ForStStateBackendFactory()

Method Detail

createFromConfig

public ForStStateBackend createFromConfig(ReadableConfig 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<ForStStateBackend>

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