Modifier and Type | Interface and Description |
---|---|
interface |
StateChangelogHandleReader<Handle extends ChangelogStateHandle>
Allows to read state changelog referenced by the provided
ChangelogStateHandle . |
interface |
StateChangelogStorage<Handle extends ChangelogStateHandle>
A storage for changelog.
|
interface |
StateChangelogWriter<Handle extends ChangelogStateHandle>
Allows to write data to the log.
|
Modifier and Type | Class and Description |
---|---|
class |
ChangelogStateHandleStreamImpl
ChangelogStateHandle implementation based on StreamStateHandle . |
Modifier and Type | Method and Description |
---|---|
List<ChangelogStateHandle> |
ChangelogStateBackendHandle.getNonMaterializedStateHandles() |
List<ChangelogStateHandle> |
ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl.getNonMaterializedStateHandles() |
Modifier and Type | Method and Description |
---|---|
static ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl |
ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl.restore(List<KeyedStateHandle> materialized,
List<ChangelogStateHandle> nonMaterialized,
KeyGroupRange keyGroupRange,
long materializationID,
long persistedSizeOfThisCheckpoint,
StateHandleID stateHandleId) |
Constructor and Description |
---|
ChangelogStateBackendHandleImpl(List<KeyedStateHandle> materialized,
List<ChangelogStateHandle> nonMaterialized,
KeyGroupRange keyGroupRange,
long materializationID,
long persistedSizeOfThisCheckpoint) |
Modifier and Type | Class and Description |
---|---|
class |
InMemoryChangelogStateHandle
In-memory
ChangelogStateHandle . |
Constructor and Description |
---|
ChangelogKeyedStateBackend(AbstractKeyedStateBackend<K> keyedStateBackend,
String subtaskName,
ExecutionConfig executionConfig,
TtlTimeProvider ttlTimeProvider,
StateChangelogWriter<? extends ChangelogStateHandle> stateChangelogWriter,
Collection<ChangelogStateBackendHandle> initialState,
CheckpointStorageWorkerView checkpointStorageWorkerView) |
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.