Uses of Interface org.apache.flink.state.changelog.ChangelogState (Flink : State backends : Changelog 1.20.1-cp3 API)

Packages that use ChangelogState
Package Description

org.apache.flink.state.changelog

org.apache.flink.state.changelog.restore

Uses of ChangelogState in org.apache.flink.state.changelog

Classes in org.apache.flink.state.changelog that implement ChangelogState
Modifier and Type	Class	Description
`class`	`ChangelogKeyGroupedPriorityQueue<T>`	A `KeyGroupedInternalPriorityQueue` that keeps state on the underlying delegated `KeyGroupedInternalPriorityQueue` as well as on the state change log.

Methods in org.apache.flink.state.changelog that return ChangelogState
Modifier and Type	Method	Description
`<K,N,V,S extends org.apache.flink.api.common.state.State> ChangelogState`	ChangelogStateFactory.`create(org.apache.flink.api.common.state.StateDescriptor<S,V> stateDescriptor, org.apache.flink.runtime.state.internal.InternalKvState<K,N,V> internalKvState, KvStateChangeLogger<V,N> kvStateChangeLogger, org.apache.flink.runtime.state.InternalKeyContext<K> keyContext)`
`ChangelogState`	ChangelogStateFactory.`getExistingState(String name, org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot.BackendStateType type)`

Uses of ChangelogState in org.apache.flink.state.changelog.restore

Methods in org.apache.flink.state.changelog.restore that return ChangelogState
Modifier and Type	Method	Description
`ChangelogState`	ChangelogMigrationRestoreTarget.`getExistingState(String name, org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot.BackendStateType type)`
`ChangelogState`	ChangelogRestoreTarget.`getExistingState(String name, org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshot.BackendStateType type)`	Returns the existing state created by `ChangelogRestoreTarget.createKeyedState(TypeSerializer, StateDescriptor)` or `ChangelogRestoreTarget.createPqState(String, TypeSerializer)` in the restore procedure.