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

Class InMemoryStateChangelogStorage

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, StateChangelogStorage<InMemoryChangelogStateHandle>, StateChangelogStorageView<InMemoryChangelogStateHandle>

public class InMemoryStateChangelogStorage
extends Object
implements StateChangelogStorage<InMemoryChangelogStateHandle>

An in-memory (non-production) implementation of StateChangelogStorage.

Constructor Summary

Constructors

Constructor	Description
InMemoryStateChangelogStorage()

Method Summary

Modifier and Type	Method	Description
StateChangelogHandleReader<InMemoryChangelogStateHandle>	createReader()
org.apache.flink.runtime.state.changelog.inmemory.InMemoryStateChangelogWriter	createWriter(String operatorID, KeyGroupRange keyGroupRange, MailboxExecutor mailboxExecutor)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.runtime.state.changelog.StateChangelogStorage

getAvailabilityProvider

Methods inherited from interface org.apache.flink.runtime.state.changelog.StateChangelogStorageView

close

Constructor Detail

InMemoryStateChangelogStorage

public InMemoryStateChangelogStorage()

Method Detail

createWriter

public org.apache.flink.runtime.state.changelog.inmemory.InMemoryStateChangelogWriter createWriter(String operatorID,
                                                                                                   KeyGroupRange keyGroupRange,
                                                                                                   MailboxExecutor mailboxExecutor)

Specified by:

createWriter in interface StateChangelogStorage<InMemoryChangelogStateHandle>

createReader

public StateChangelogHandleReader<InMemoryChangelogStateHandle> createReader()

Specified by:

createReader in interface StateChangelogStorageView<InMemoryChangelogStateHandle>