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

Class AsynchronousBufferFileSegmentReader

java.lang.Object

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

org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannel<FileSegment,org.apache.flink.runtime.io.disk.iomanager.ReadRequest>

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

All Implemented Interfaces:

BufferFileSegmentReader, FileIOChannel

public class AsynchronousBufferFileSegmentReader
extends AsynchronousFileIOChannel<FileSegment,org.apache.flink.runtime.io.disk.iomanager.ReadRequest>
implements BufferFileSegmentReader

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.io.disk.iomanager.FileIOChannel

FileIOChannel.Enumerator, FileIOChannel.ID

Field Summary

Fields inherited from class org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannel

closed, closeLock, exception, requestQueue, requestsNotReturned, resultHandler

Fields inherited from class org.apache.flink.runtime.io.disk.iomanager.AbstractFileIOChannel

fileChannel, id, LOG

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AsynchronousBufferFileSegmentReader(FileIOChannel.ID channelID, RequestQueue<org.apache.flink.runtime.io.disk.iomanager.ReadRequest> requestQueue, RequestDoneCallback<FileSegment> callback)

Method Summary

Modifier and Type	Method	Description
boolean	hasReachedEndOfFile()
void	read()
void	seekTo(long position)

Methods inherited from class org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannel

addRequest, checkErroneous, close, closeAndDelete, handleProcessedBuffer, isClosed, registerAllRequestsProcessedListener

Methods inherited from class org.apache.flink.runtime.io.disk.iomanager.AbstractFileIOChannel

deleteChannel, getChannelID, getNioFileChannel, getSize

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.runtime.io.disk.iomanager.FileIOChannel

close, closeAndDelete, deleteChannel, getChannelID, getNioFileChannel, getSize, isClosed

Constructor Detail

AsynchronousBufferFileSegmentReader

protected AsynchronousBufferFileSegmentReader(FileIOChannel.ID channelID,
                                              RequestQueue<org.apache.flink.runtime.io.disk.iomanager.ReadRequest> requestQueue,
                                              RequestDoneCallback<FileSegment> callback)
                                       throws IOException

Throws:

IOException

Method Detail

read

public void read()
          throws IOException

Specified by:

read in interface BufferFileSegmentReader

Throws:

IOException

seekTo

public void seekTo(long position)
            throws IOException

Specified by:

seekTo in interface BufferFileSegmentReader

Throws:

IOException

hasReachedEndOfFile

public boolean hasReachedEndOfFile()

Specified by:

hasReachedEndOfFile in interface BufferFileSegmentReader