Interface Reader<T extends IOReadableWritable>
-
- All Superinterfaces:
ReaderBase
- All Known Implementing Classes:
RecordReader
public interface Reader<T extends IOReadableWritable> extends ReaderBase
A record-oriented reader for immutable record types.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
clearBuffers()
boolean
hasNext()
T
next()
-
Methods inherited from interface org.apache.flink.runtime.io.network.api.reader.ReaderBase
hasReachedEndOfSuperstep, isFinished, registerTaskEventListener, sendTaskEvent, setIterativeReader, startNextSuperstep
-
-
-
-
Method Detail
-
hasNext
boolean hasNext() throws IOException, InterruptedException
- Throws:
IOException
InterruptedException
-
next
T next() throws IOException, InterruptedException
- Throws:
IOException
InterruptedException
-
clearBuffers
void clearBuffers()
-
-