Package | Description |
---|---|
org.apache.flink.state.changelog | |
org.apache.flink.state.changelog.restore |
Class and Description |
---|
AbstractChangelogStateBackend
An abstract base implementation of the
StateBackend interface whose subclasses use
delegatedStateBackend and State changes to restore. |
ChangelogKeyGroupedPriorityQueue
A
KeyGroupedInternalPriorityQueue that keeps state on the underlying delegated KeyGroupedInternalPriorityQueue as well as on the state change log. |
ChangelogState
State used by
ChangelogKeyedStateBackend . |
ChangelogStateFactory
Maintains the lifecycle of all
ChangelogState s. |
KvStateChangeLogger
A logger for some key-partitioned state (not only
ValueState . |
StateChangeLogger
Logs changes to a state created by
ChangelogKeyedStateBackend . |
StateChangeOperation
The operation applied to
ChangelogState . |
Class and Description |
---|
ChangelogState
State used by
ChangelogKeyedStateBackend . |
ChangelogStateFactory
Maintains the lifecycle of all
ChangelogState s. |
StateChangeOperation
The operation applied to
ChangelogState . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.