Package | Description |
---|---|
org.apache.flink.runtime.io.disk.iomanager | |
org.apache.flink.table.runtime.io |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
CompressedBlockChannelReader
Compressed block channel reader provides a scenario where MemorySegment must be maintained.
|
class |
CompressedHeaderlessChannelReaderInputView
A
DataInputView that is backed by a
BufferFileReader , making it effectively a data input stream. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.