All Classes
-
All Classes Interface Summary Class Summary Enum Summary Class Description AbstractChangelogStateBackend An abstract base implementation of theStateBackendinterface whose subclasses use delegatedStateBackend and State changes to restore.ChangelogApplierFactory StateChangeApplierfactory.ChangelogBackendRestoreOperation RestoresChangelogKeyedStateBackendfrom the providedhandles.ChangelogBackendRestoreOperation.BaseBackendBuilder<K> Builds base backend forChangelogKeyedStateBackendfrom state.ChangelogBackendRestoreOperation.ChangelogRestoreTargetBuilder<K> BuildsChangelogRestoreTargetfrom the base backend and state.ChangelogKeyedStateBackend<K> AKeyedStateBackendthat keeps state on the underlying delegated keyed state backend as well as on the state change log.ChangelogKeyGroupedPriorityQueue<T> AKeyGroupedInternalPriorityQueuethat keeps state on the underlying delegatedKeyGroupedInternalPriorityQueueas well as on the state change log.ChangelogMigrationRestoreTarget<K> AChangelogRestoreTargetsupports to migrate to the delegated keyed state backend.ChangelogRestoreTarget<K> Maintains metadata operation related to Changelog recovery.ChangelogState State used byChangelogKeyedStateBackend.ChangelogStateBackend This state backend holds the working state in the underlying delegatedStateBackend, and forwards state changes to State Changelog.ChangelogStateFactory Maintains the lifecycle of allChangelogStates.DeactivatedChangelogStateBackend This state backend use delegatedStateBackend and State changes to restore to the delegatedStateBackend in which switching Changelog from enabled to disabled.FunctionDelegationHelper Delegating functionsare used to create metadata on recovery when the actual function code is not known yet.KvStateChangeLogger<Value,Namespace> A logger for some key-partitioned state (not onlyValueState.StateChangeApplier Applies state data change to some state.StateChangeLogger<Value,Namespace> Logs changes to a state created byChangelogKeyedStateBackend.StateChangeOperation The operation applied toChangelogState.