Uses of Package
org.apache.flink.state.changelog
-
Packages that use org.apache.flink.state.changelog Package Description org.apache.flink.state.changelog org.apache.flink.state.changelog.restore -
Classes in org.apache.flink.state.changelog used by org.apache.flink.state.changelog Class Description AbstractChangelogStateBackend An abstract base implementation of theStateBackendinterface whose subclasses use delegatedStateBackend and State changes to restore.ChangelogKeyGroupedPriorityQueue AKeyGroupedInternalPriorityQueuethat keeps state on the underlying delegatedKeyGroupedInternalPriorityQueueas well as on the state change log.ChangelogState State used byChangelogKeyedStateBackend.ChangelogStateFactory Maintains the lifecycle of allChangelogStates.KvStateChangeLogger A logger for some key-partitioned state (not onlyValueState.StateChangeLogger Logs changes to a state created byChangelogKeyedStateBackend.StateChangeOperation The operation applied toChangelogState. -
Classes in org.apache.flink.state.changelog used by org.apache.flink.state.changelog.restore Class Description ChangelogState State used byChangelogKeyedStateBackend.ChangelogStateFactory Maintains the lifecycle of allChangelogStates.StateChangeOperation The operation applied toChangelogState.