org.apache.flink.contrib.streaming.state

Class EmbeddedRocksDBStateBackendFactory

java.lang.Object

org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackendFactory

All Implemented Interfaces:

StateBackendFactory<EmbeddedRocksDBStateBackend>

@PublicEvolving
public class EmbeddedRocksDBStateBackendFactory
extends Object
implements StateBackendFactory<EmbeddedRocksDBStateBackend>

A factory that creates an EmbeddedRocksDBStateBackend from a configuration.

Constructor Summary

Constructors

Constructor and Description
EmbeddedRocksDBStateBackendFactory()

Method Summary

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

EmbeddedRocksDBStateBackendFactory

public EmbeddedRocksDBStateBackendFactory()

Method Detail

createFromConfig

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

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