Uses of Class
org.apache.flink.runtime.state.changelog.ChangelogStateHandleStreamImpl

Packages that use ChangelogStateHandleStreamImpl

Package	Description
org.apache.flink.changelog.fs
org.apache.flink.runtime.state.changelog

Uses of ChangelogStateHandleStreamImpl in org.apache.flink.changelog.fs

Methods in org.apache.flink.changelog.fs that return types with arguments of type ChangelogStateHandleStreamImpl

Modifier and Type	Method and Description
StateChangelogHandleReader<ChangelogStateHandleStreamImpl>	FsStateChangelogStorageForRecovery.createReader()

Uses of ChangelogStateHandleStreamImpl in org.apache.flink.runtime.state.changelog

Methods in org.apache.flink.runtime.state.changelog that return ChangelogStateHandleStreamImpl

Modifier and Type	Method and Description
static ChangelogStateHandleStreamImpl	ChangelogStateHandleStreamImpl.restore(List<Tuple2<StreamStateHandle,Long>> handlesAndOffsets, KeyGroupRange keyGroupRange, long size, long incrementalSize, String storageIdentifier, StateHandleID stateHandleID)

Methods in org.apache.flink.runtime.state.changelog with parameters of type ChangelogStateHandleStreamImpl

Modifier and Type	Method and Description
CloseableIterator<StateChange>	StateChangelogHandleStreamHandleReader.getChanges(ChangelogStateHandleStreamImpl handle)