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