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