org.apache.flink.runtime.state.changelog

Interface StateChangelogHandleReader<Handle extends ChangelogStateHandle>

All Known Implementing Classes:

StateChangelogHandleStreamHandleReader

@Internal
public interface StateChangelogHandleReader<Handle extends ChangelogStateHandle>

Allows to read state changelog referenced by the provided ChangelogStateHandle.

Method Summary

Modifier and Type	Method and Description
CloseableIterator<StateChange>	getChanges(Handle handle)

Method Detail

getChanges

CloseableIterator<StateChange> getChanges(Handle handle)
                                   throws IOException

Throws:

IOException