Package | Description |
---|---|
org.apache.flink.runtime.io.disk.iomanager |
Modifier and Type | Class and Description |
---|---|
class |
QueuingCallback<T>
A
RequestDoneCallback that adds the memory segments to a blocking queue. |
Modifier and Type | Field and Description |
---|---|
protected RequestDoneCallback<T> |
AsynchronousFileIOChannel.resultHandler
Handler for completed requests
|
Constructor and Description |
---|
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) |
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.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.