Modifier and Type | Method and Description |
---|---|
StateChangelogStorageView<?> |
TaskStateManager.getStateChangelogStorageView(Configuration configuration,
ChangelogStateHandle changelogStateHandle)
Returns the state changelog storage view of given
ChangelogStateHandle for this task. |
StateChangelogStorageView<?> |
TaskStateManagerImpl.getStateChangelogStorageView(Configuration configuration,
ChangelogStateHandle changelogStateHandle) |
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 |
StateChangelogStorageView<Handle extends ChangelogStateHandle>
A storage view 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> |
ChangelogStateBackendLocalHandle.getNonMaterializedStateHandles() |
List<ChangelogStateHandle> |
ChangelogStateBackendHandle.getNonMaterializedStateHandles() |
List<ChangelogStateHandle> |
ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl.getNonMaterializedStateHandles() |
List<ChangelogStateHandle> |
ChangelogStateBackendLocalHandle.getRemoteNonMaterializedStateHandles() |
Modifier and Type | Method and Description |
---|---|
static StateChangelogStorageView<?> |
StateChangelogStorageLoader.loadFromStateHandle(Configuration configuration,
ChangelogStateHandle changelogStateHandle) |
Modifier and Type | Method and Description |
---|---|
static ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl |
ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl.restore(List<KeyedStateHandle> materialized,
List<ChangelogStateHandle> nonMaterialized,
KeyGroupRange keyGroupRange,
long checkpointId,
long materializationID,
long persistedSizeOfThisCheckpoint,
StateHandleID stateHandleId) |
Constructor and Description |
---|
ChangelogStateBackendHandleImpl(List<KeyedStateHandle> materialized,
List<ChangelogStateHandle> nonMaterialized,
KeyGroupRange keyGroupRange,
long checkpointId,
long materializationID,
long persistedSizeOfThisCheckpoint) |
ChangelogStateBackendLocalHandle(List<KeyedStateHandle> localMaterialized,
List<ChangelogStateHandle> localNonMaterialized,
ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl remoteHandle) |
Modifier and Type | Class and Description |
---|---|
class |
InMemoryChangelogStateHandle
In-memory
ChangelogStateHandle . |
Constructor and Description |
---|
ChangelogKeyedStateBackend(AbstractKeyedStateBackend<K> keyedStateBackend,
String subtaskName,
ExecutionConfig executionConfig,
TtlTimeProvider ttlTimeProvider,
org.apache.flink.state.changelog.ChangelogStateBackendMetricGroup metricGroup,
StateChangelogWriter<? extends ChangelogStateHandle> stateChangelogWriter,
Collection<ChangelogStateBackendHandle> initialState,
CheckpointStorageWorkerView checkpointStorageWorkerView) |
ChangelogKeyedStateBackend(AbstractKeyedStateBackend<K> keyedStateBackend,
String subtaskName,
ExecutionConfig executionConfig,
TtlTimeProvider ttlTimeProvider,
org.apache.flink.state.changelog.ChangelogStateBackendMetricGroup metricGroup,
StateChangelogWriter<? extends ChangelogStateHandle> stateChangelogWriter,
Collection<ChangelogStateBackendHandle> initialState,
CheckpointStorageWorkerView checkpointStorageWorkerView,
ChangelogStateFactory changelogStateFactory) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.