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

Class AsynchronousBulkBlockReader

java.lang.Object

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

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

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

All Implemented Interfaces:

BulkBlockChannelReader, FileIOChannel

public class AsynchronousBulkBlockReader
extends AsynchronousFileIOChannel<MemorySegment,org.apache.flink.runtime.io.disk.iomanager.ReadRequest>
implements BulkBlockChannelReader

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	AsynchronousBulkBlockReader(FileIOChannel.ID channelID, RequestQueue<org.apache.flink.runtime.io.disk.iomanager.ReadRequest> requestQueue, List<MemorySegment> sourceSegments, int numBlocks)

Method Summary

Modifier and Type	Method	Description
List<MemorySegment>	getFullSegments()

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

AsynchronousBulkBlockReader

protected AsynchronousBulkBlockReader(FileIOChannel.ID channelID,
                                      RequestQueue<org.apache.flink.runtime.io.disk.iomanager.ReadRequest> requestQueue,
                                      List<MemorySegment> sourceSegments,
                                      int numBlocks)
                               throws IOException

Throws:

IOException

Method Detail

getFullSegments

public List<MemorySegment> getFullSegments()

Specified by:

getFullSegments in interface BulkBlockChannelReader