@Internal public interface StateChangelogStorage<Handle extends ChangelogStateHandle> extends AutoCloseable
StateChangelogHandleReader
and StateChangelogWriter
for read and write. Please use StateChangelogStorageLoader
to
obtain an instance.Modifier and Type | Method and Description |
---|---|
default void |
close() |
StateChangelogHandleReader<Handle> |
createReader() |
StateChangelogWriter<Handle> |
createWriter(String operatorID,
KeyGroupRange keyGroupRange,
MailboxExecutor mailboxExecutor) |
default AvailabilityProvider |
getAvailabilityProvider() |
StateChangelogWriter<Handle> createWriter(String operatorID, KeyGroupRange keyGroupRange, MailboxExecutor mailboxExecutor)
StateChangelogHandleReader<Handle> createReader()
default void close() throws Exception
close
in interface AutoCloseable
Exception
default AvailabilityProvider getAvailabilityProvider()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.