public class InMemoryStateChangelogWriterFactory extends Object implements StateChangelogWriterFactory<org.apache.flink.runtime.state.changelog.inmemory.InMemoryStateChangelogHandle>
StateChangelogWriterFactory
.Constructor and Description |
---|
InMemoryStateChangelogWriterFactory() |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.runtime.state.changelog.inmemory.InMemoryStateChangelogWriter |
createWriter(OperatorID operatorID,
KeyGroupRange keyGroupRange) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public org.apache.flink.runtime.state.changelog.inmemory.InMemoryStateChangelogWriter createWriter(OperatorID operatorID, KeyGroupRange keyGroupRange)
createWriter
in interface StateChangelogWriterFactory<org.apache.flink.runtime.state.changelog.inmemory.InMemoryStateChangelogHandle>
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.