AbstractChannelReaderInputView (Flink : 2.0-SNAPSHOT API)

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 Description

AbstractChannelReaderInputView(int headerLength)

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	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.