org.apache.flink.runtime.state.memory

Class MemoryStateBackendFactory

java.lang.Object

org.apache.flink.runtime.state.memory.MemoryStateBackendFactory

All Implemented Interfaces:

StateBackendFactory<MemoryStateBackend>

@PublicEvolving
public class MemoryStateBackendFactory
extends Object
implements StateBackendFactory<MemoryStateBackend>

A factory that creates an MemoryStateBackend from a configuration.

Constructor Summary

Constructors

Constructor and Description
MemoryStateBackendFactory()

Method Summary

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

MemoryStateBackendFactory

public MemoryStateBackendFactory()

Method Detail

createFromConfig

public MemoryStateBackend createFromConfig(ReadableConfig config,
                                           ClassLoader classLoader)

Description copied from interface: StateBackendFactory

Creates the state backend, optionally using the given configuration.

Specified by:

createFromConfig in interface StateBackendFactory<MemoryStateBackend>

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.