public final class BufferReader extends AbstractReader
inputGate
Constructor and Description |
---|
BufferReader(InputGate gate) |
Modifier and Type | Method and Description |
---|---|
Buffer |
getNextBuffer() |
void |
setReporter(AccumulatorRegistry.Reporter reporter)
Setter for the reporter, e.g.
|
handleEvent, hasReachedEndOfSuperstep, isFinished, publish, registerTaskEventListener, sendTaskEvent, setIterativeReader, startNextSuperstep
public BufferReader(InputGate gate)
public Buffer getNextBuffer() throws IOException, InterruptedException
IOException
InterruptedException
public void setReporter(AccumulatorRegistry.Reporter reporter)
ReaderBase
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.