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
getAvailabilityProvider
close
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 StateChangelogStorageView<InMemoryChangelogStateHandle>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.