@Internal public interface StateChangelogWriterFactory<Handle extends StateChangelogHandle<?>> extends AutoCloseable
StateChangelogWriter
factory. Scoped to a single entity (e.g. a SubTask or
OperatorCoordinator). Please use StateChangelogWriterFactoryLoader
to obtain an instance.Modifier and Type | Method and Description |
---|---|
default void |
close() |
StateChangelogWriter<Handle> |
createWriter(OperatorID operatorID,
KeyGroupRange keyGroupRange) |
StateChangelogWriter<Handle> createWriter(OperatorID operatorID, KeyGroupRange keyGroupRange)
default void close() throws Exception
close
in interface AutoCloseable
Exception
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.