Package | Description |
---|---|
org.apache.flink.state.changelog.restore |
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.