org.apache.flink.runtime.state.hashmap

Class HashMapStateBackendFactory

java.lang.Object

org.apache.flink.runtime.state.hashmap.HashMapStateBackendFactory

All Implemented Interfaces:

StateBackendFactory<HashMapStateBackend>

@PublicEvolving
public class HashMapStateBackendFactory
extends Object
implements StateBackendFactory<HashMapStateBackend>

A factory that creates an HashMapStateBackend from a configuration.

Constructor Summary

Constructors

Constructor and Description
HashMapStateBackendFactory()

Method Summary

Modifier and Type	Method and Description
HashMapStateBackend	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

HashMapStateBackendFactory

public HashMapStateBackendFactory()

Method Detail

createFromConfig

public HashMapStateBackend 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<HashMapStateBackend>

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