Modifier and Type | Method and Description |
---|---|
StateChangelogHandleReader<ChangelogStateHandleStreamImpl> |
FsStateChangelogStorage.createReader() |
Modifier and Type | Class and Description |
---|---|
class |
StateChangelogHandleStreamHandleReader
A reader for
ChangelogStateHandleStreamImpl that iterates over its underlying stream handles and offsets. |
Modifier and Type | Method and Description |
---|---|
StateChangelogHandleReader<Handle> |
StateChangelogStorage.createReader() |
Modifier and Type | Method and Description |
---|---|
StateChangelogHandleReader<InMemoryChangelogStateHandle> |
InMemoryStateChangelogStorage.createReader() |
Modifier and Type | Method and Description |
---|---|
static <K,T extends ChangelogStateHandle> |
ChangelogBackendRestoreOperation.restore(StateChangelogHandleReader<T> changelogHandleReader,
ClassLoader classLoader,
Collection<ChangelogStateBackendHandle> stateHandles,
ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder,
ChangelogBackendRestoreOperation.DeltaBackendBuilder<K> changelogBackendBuilder) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.