Package | Description |
---|---|
org.apache.flink.state.changelog | |
org.apache.flink.state.changelog.restore |
Class and Description |
---|
ChangelogApplierFactory
StateChangeApplier factory. |
ChangelogBackendRestoreOperation.BaseBackendBuilder
Builds base backend for
ChangelogKeyedStateBackend from state. |
ChangelogRestoreTarget
Maintains metadata operation related to Changelog recovery.
|
StateChangeApplier
Applies state data change to some state.
|
Class and Description |
---|
ChangelogBackendRestoreOperation.BaseBackendBuilder
Builds base backend for
ChangelogKeyedStateBackend from state. |
ChangelogBackendRestoreOperation.ChangelogRestoreTargetBuilder
Builds
ChangelogRestoreTarget from the base backend and state. |
ChangelogRestoreTarget
Maintains metadata operation related to Changelog recovery.
|
StateChangeApplier
Applies state data change to some state.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.