Package org.apache.flink.state.changelog.restore
-
Interface Summary Interface Description ChangelogApplierFactory StateChangeApplierfactory.ChangelogBackendRestoreOperation.BaseBackendBuilder<K> Builds base backend forChangelogKeyedStateBackendfrom state.ChangelogBackendRestoreOperation.ChangelogRestoreTargetBuilder<K> BuildsChangelogRestoreTargetfrom the base backend and state.ChangelogRestoreTarget<K> Maintains metadata operation related to Changelog recovery.StateChangeApplier Applies state data change to some state. -
Class Summary Class Description ChangelogBackendRestoreOperation RestoresChangelogKeyedStateBackendfrom the providedhandles.ChangelogMigrationRestoreTarget<K> AChangelogRestoreTargetsupports to migrate to the delegated keyed state backend.FunctionDelegationHelper Delegating functionsare used to create metadata on recovery when the actual function code is not known yet.