org.apache.flink.runtime.io.disk.iomanager

Class AbstractChannelReaderInputView

java.lang.Object

org.apache.flink.runtime.memory.AbstractPagedInputView

org.apache.flink.runtime.io.disk.iomanager.AbstractChannelReaderInputView

All Implemented Interfaces:

DataInput, DataInputView

Direct Known Subclasses:

ChannelReaderInputView, CompressedHeaderlessChannelReaderInputView

public abstract class AbstractChannelReaderInputView
extends AbstractPagedInputView

A DataInputView that is backed by a FileIOChannel, making it effectively a data input stream. The view reads it data in blocks from the underlying channel. The view can only read data that has been written by a ChannelWriterOutputView, due to block formatting.

Field Summary

Fields inherited from class org.apache.flink.runtime.memory.AbstractPagedInputView

headerLength

Constructor Summary

Constructors

Constructor and Description
AbstractChannelReaderInputView(int headerLength)

Method Summary

Modifier and Type	Method and Description
abstract List<MemorySegment>	close() Closes this InputView, closing the underlying reader and returning all memory segments.
abstract FileIOChannel	getChannel() Get the underlying channel.

Methods inherited from class org.apache.flink.runtime.memory.AbstractPagedInputView

advance, clear, doAdvance, getCurrentPositionInSegment, getCurrentSegment, getCurrentSegmentLimit, getHeaderLength, getLimitForSegment, nextSegment, read, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, readUTF, seekInput, skipBytes, skipBytesToRead

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractChannelReaderInputView

public AbstractChannelReaderInputView(int headerLength)

Method Detail

close

public abstract List<MemorySegment> close()
                                   throws IOException

Closes this InputView, closing the underlying reader and returning all memory segments.

Returns:

A list containing all memory segments originally supplied to this view.

Throws:

IOException - Thrown, if the underlying reader could not be properly closed.

getChannel

public abstract FileIOChannel getChannel()

Get the underlying channel.