org.apache.flink.runtime.io.network.api.reader

Class BufferReader

java.lang.Object

org.apache.flink.runtime.io.network.api.reader.AbstractReader

org.apache.flink.runtime.io.network.api.reader.BufferReader

All Implemented Interfaces:

ReaderBase

public final class BufferReader
extends AbstractReader

A buffer-oriented reader.

Field Summary

Fields inherited from class org.apache.flink.runtime.io.network.api.reader.AbstractReader

inputGate

Constructor Summary

Constructors

Constructor and Description
BufferReader(InputGate gate)

Method Summary

Modifier and Type	Method and Description
Buffer	getNextBuffer()

Methods inherited from class org.apache.flink.runtime.io.network.api.reader.AbstractReader

handleEvent, hasReachedEndOfSuperstep, isFinished, publish, registerTaskEventListener, sendTaskEvent, setIterativeReader, startNextSuperstep

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BufferReader

public BufferReader(InputGate gate)

Method Detail

getNextBuffer

public Buffer getNextBuffer()
                     throws IOException,
                            InterruptedException

Throws:

IOException

InterruptedException