org.apache.flink.streaming.api.operators

Interface InternalTimersSnapshotReaderWriters.InternalTimersSnapshotReader<K,N>

Enclosing class:

InternalTimersSnapshotReaderWriters

public static interface InternalTimersSnapshotReaderWriters.InternalTimersSnapshotReader<K,N>

A reader for a InternalTimersSnapshot.

Method Summary

Modifier and Type	Method and Description
InternalTimersSnapshot<K,N>	readTimersSnapshot(DataInputView in) Reads a timers snapshot from the provided input view.

Method Detail

readTimersSnapshot

InternalTimersSnapshot<K,N> readTimersSnapshot(DataInputView in)
                                        throws IOException

Reads a timers snapshot from the provided input view.

Parameters:

in - the input view

Returns:

the read timers snapshot

Throws:

IOException