public interface Reader<T extends IOReadableWritable> extends ReaderBase
Modifier and Type | Method and Description |
---|---|
void |
clearBuffers() |
boolean |
hasNext() |
T |
next() |
hasReachedEndOfSuperstep, isFinished, registerTaskEventListener, sendTaskEvent, setIterativeReader, startNextSuperstep
boolean hasNext() throws IOException, InterruptedException
IOException
InterruptedException
T next() throws IOException, InterruptedException
IOException
InterruptedException
void clearBuffers()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.