public class MutableRecordReader<T extends IOReadableWritable> extends AbstractReader implements MutableReader<T>
inputGate
Constructor and Description |
---|
MutableRecordReader(InputGate inputGate) |
Modifier and Type | Method and Description |
---|---|
void |
clearBuffers() |
protected boolean |
getNextRecord(T target) |
boolean |
next(T target) |
void |
setReporter(AccumulatorRegistry.Reporter reporter)
Setter for the reporter, e.g.
|
handleEvent, hasReachedEndOfSuperstep, isFinished, publish, registerTaskEventListener, sendTaskEvent, setIterativeReader, startNextSuperstep
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
hasReachedEndOfSuperstep, isFinished, registerTaskEventListener, sendTaskEvent, setIterativeReader, setReporter, startNextSuperstep
public MutableRecordReader(InputGate inputGate)
public boolean next(T target) throws IOException, InterruptedException
next
in interface MutableReader<T extends IOReadableWritable>
IOException
InterruptedException
public void clearBuffers()
clearBuffers
in interface MutableReader<T extends IOReadableWritable>
protected boolean getNextRecord(T target) throws IOException, InterruptedException
IOException
InterruptedException
public void setReporter(AccumulatorRegistry.Reporter reporter)
ReaderBase
setReporter
in interface ReaderBase
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.