public class InMemoryStateChangelogStorage extends Object implements StateChangelogStorage<InMemoryChangelogStateHandle>
StateChangelogStorage
.Constructor and Description |
---|
InMemoryStateChangelogStorage() |
Modifier and Type | Method and Description |
---|---|
StateChangelogHandleReader<InMemoryChangelogStateHandle> |
createReader() |
org.apache.flink.runtime.state.changelog.inmemory.InMemoryStateChangelogWriter |
createWriter(String operatorID,
KeyGroupRange keyGroupRange,
MailboxExecutor mailboxExecutor) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, getAvailabilityProvider
public org.apache.flink.runtime.state.changelog.inmemory.InMemoryStateChangelogWriter createWriter(String operatorID, KeyGroupRange keyGroupRange, MailboxExecutor mailboxExecutor)
createWriter
in interface StateChangelogStorage<InMemoryChangelogStateHandle>
public StateChangelogHandleReader<InMemoryChangelogStateHandle> createReader()
createReader
in interface StateChangelogStorage<InMemoryChangelogStateHandle>
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.