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