org.apache.flink.runtime.state.changelog

Interface StateChangelogHandleStreamHandleReader.StateChangeIterator

Enclosing class:

StateChangelogHandleStreamHandleReader

public static interface StateChangelogHandleStreamHandleReader.StateChangeIterator

Reads a stream of state changes starting from a specified offset.

Method Summary

Modifier and Type	Method and Description
CloseableIterator<StateChange>	read(StreamStateHandle handle, long offset)

Method Detail

read

CloseableIterator<StateChange> read(StreamStateHandle handle,
                                    long offset)
                             throws IOException

Throws:

IOException