Package | Description |
---|---|
org.apache.flink.runtime.state.changelog | |
org.apache.flink.state.changelog | |
org.apache.flink.state.changelog.restore |
Modifier and Type | Class and Description |
---|---|
static class |
ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl |
class |
ChangelogStateBackendLocalHandle
State handle for local copies of
ChangelogStateHandleStreamImpl . |
Modifier and Type | Method and Description |
---|---|
static ChangelogStateBackendHandle |
ChangelogStateBackendHandle.ChangelogStateBackendHandleImpl.getChangelogStateBackendHandle(KeyedStateHandle originKeyedStateHandle) |
ChangelogStateBackendHandle |
ChangelogStateBackendHandle.rebound(long checkpointId) |
ChangelogStateBackendHandle |
ChangelogStateBackendLocalHandle.rebound(long checkpointId) |
Modifier and Type | Method and Description |
---|---|
protected <K> CheckpointableKeyedStateBackend<K> |
DeactivatedChangelogStateBackend.restore(Environment env,
String operatorIdentifier,
KeyGroupRange keyGroupRange,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<ChangelogStateBackendHandle> stateBackendHandles,
ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder) |
protected <K> CheckpointableKeyedStateBackend<K> |
ChangelogStateBackend.restore(Environment env,
String operatorIdentifier,
KeyGroupRange keyGroupRange,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<ChangelogStateBackendHandle> stateBackendHandles,
ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder) |
protected abstract <K> CheckpointableKeyedStateBackend<K> |
AbstractChangelogStateBackend.restore(Environment env,
String operatorIdentifier,
KeyGroupRange keyGroupRange,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<ChangelogStateBackendHandle> stateBackendHandles,
ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder) |
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) |
Modifier and Type | Method and Description |
---|---|
static <K> CheckpointableKeyedStateBackend<K> |
ChangelogBackendRestoreOperation.restore(Configuration configuration,
ClassLoader classLoader,
TaskStateManager taskStateManager,
Collection<ChangelogStateBackendHandle> stateHandles,
ChangelogBackendRestoreOperation.BaseBackendBuilder<K> baseBackendBuilder,
ChangelogBackendRestoreOperation.ChangelogRestoreTargetBuilder<K> changelogRestoreTargetBuilder) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.