Package org.apache.flink.state.changelog.restore
-
Interface Summary Interface Description ChangelogApplierFactory StateChangeApplier
factory.ChangelogBackendRestoreOperation.BaseBackendBuilder<K> Builds base backend forChangelogKeyedStateBackend
from state.ChangelogBackendRestoreOperation.ChangelogRestoreTargetBuilder<K> BuildsChangelogRestoreTarget
from 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 RestoresChangelogKeyedStateBackend
from the providedhandles
.ChangelogMigrationRestoreTarget<K> AChangelogRestoreTarget
supports to migrate to the delegated keyed state backend.FunctionDelegationHelper Delegating functions
are used to create metadata on recovery when the actual function code is not known yet.