org.apache.flink.runtime.state.changelog.inmemory

Class InMemoryStateChangelogStorageFactory

java.lang.Object

org.apache.flink.runtime.state.changelog.inmemory.InMemoryStateChangelogStorageFactory

All Implemented Interfaces:

StateChangelogStorageFactory

public class InMemoryStateChangelogStorageFactory
extends Object
implements StateChangelogStorageFactory

An StateChangelogStorageFactory for creating InMemoryStateChangelogStorage.

Field Summary

Fields

Modifier and Type	Field and Description
static String	identifier

Constructor Summary

Constructors

Constructor and Description
InMemoryStateChangelogStorageFactory()

Method Summary

Modifier and Type	Method and Description
StateChangelogStorage<?>	createStorage(Configuration configuration, TaskManagerJobMetricGroup metricGroup) Create the storage based on a configuration.
String	getIdentifier() Get the identifier for user to use this changelog storage factory.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

identifier

public static String identifier

Constructor Detail

InMemoryStateChangelogStorageFactory

public InMemoryStateChangelogStorageFactory()

Method Detail

getIdentifier

public String getIdentifier()

Description copied from interface: StateChangelogStorageFactory

Get the identifier for user to use this changelog storage factory.

Specified by:

getIdentifier in interface StateChangelogStorageFactory

createStorage

public StateChangelogStorage<?> createStorage(Configuration configuration,
                                              TaskManagerJobMetricGroup metricGroup)

Description copied from interface: StateChangelogStorageFactory

Create the storage based on a configuration.

Specified by:

createStorage in interface StateChangelogStorageFactory