Package | Description |
---|---|
org.apache.flink.state.changelog.restore |
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–2024 The Apache Software Foundation. All rights reserved.