Uses of Class
org.apache.flink.runtime.io.disk.iomanager.RequestQueue

Packages that use RequestQueue

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

Uses of RequestQueue in org.apache.flink.runtime.io.disk.iomanager

Fields in org.apache.flink.runtime.io.disk.iomanager declared as RequestQueue

Modifier and Type	Field	Description
protected RequestQueue<R>	AsynchronousFileIOChannel.requestQueue	A request queue for submitting asynchronous requests to the corresponding IO worker thread.

Constructors in org.apache.flink.runtime.io.disk.iomanager with parameters of type RequestQueue

Constructor	Description
AsynchronousBlockReader(FileIOChannel.ID channelID, RequestQueue<org.apache.flink.runtime.io.disk.iomanager.ReadRequest> requestQueue, LinkedBlockingQueue<MemorySegment> returnSegments)	Creates a new block channel reader for the given channel.
AsynchronousBlockWriter(FileIOChannel.ID channelID, RequestQueue<org.apache.flink.runtime.io.disk.iomanager.WriteRequest> requestQueue, LinkedBlockingQueue<MemorySegment> returnSegments)	Creates a new block channel writer for the given channel.
AsynchronousBlockWriterWithCallback(FileIOChannel.ID channelID, RequestQueue<org.apache.flink.runtime.io.disk.iomanager.WriteRequest> requestQueue, RequestDoneCallback<MemorySegment> callback)	Creates a new asynchronous block writer for the given channel.
AsynchronousBufferFileReader(FileIOChannel.ID channelID, RequestQueue<org.apache.flink.runtime.io.disk.iomanager.ReadRequest> requestQueue, RequestDoneCallback<Buffer> callback)
AsynchronousBufferFileSegmentReader(FileIOChannel.ID channelID, RequestQueue<org.apache.flink.runtime.io.disk.iomanager.ReadRequest> requestQueue, RequestDoneCallback<FileSegment> callback)
AsynchronousBufferFileWriter(FileIOChannel.ID channelID, RequestQueue<org.apache.flink.runtime.io.disk.iomanager.WriteRequest> requestQueue)
AsynchronousBulkBlockReader(FileIOChannel.ID channelID, RequestQueue<org.apache.flink.runtime.io.disk.iomanager.ReadRequest> requestQueue, List<MemorySegment> sourceSegments, int numBlocks)
AsynchronousFileIOChannel(FileIOChannel.ID channelID, RequestQueue<R> requestQueue, RequestDoneCallback<T> callback, boolean writeEnabled)	Creates a new channel access to the path indicated by the given ID.