InMemoryStateChangelogStorageFactory (Flink : 2.0-SNAPSHOT API)

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 Description

static String IDENTIFIER

Constructor Summary

Constructors
Constructor Description

InMemoryStateChangelogStorageFactory()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`StateChangelogStorage<?>`	`createStorage(JobID jobID, Configuration configuration, TaskManagerJobMetricGroup metricGroup, LocalRecoveryConfig localRecoveryConfig)`	Create the storage based on a configuration.
`StateChangelogStorageView<?>`	`createStorageView(Configuration configuration)`	Create the storage for recovery.
`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 final String IDENTIFIER
```
    See Also:
    
    Constant Field Values
- 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(JobID jobID,
                                              Configuration configuration,
                                              TaskManagerJobMetricGroup metricGroup,
                                              LocalRecoveryConfig localRecoveryConfig)
```
    Description copied from interface: StateChangelogStorageFactory
    
    Create the storage based on a configuration.
    
    Specified by:
    
    createStorage in interface StateChangelogStorageFactory
  - createStorageView
```
public StateChangelogStorageView<?> createStorageView(Configuration configuration)
```
    Description copied from interface: StateChangelogStorageFactory
    
    Create the storage for recovery.
    
    Specified by:
    
    createStorageView in interface StateChangelogStorageFactory