Interface | Description |
---|---|
BlockChannelReader<T> |
A reader that reads data in blocks from a file channel.
|
BlockChannelWriter<T> |
A writer that writes data in blocks to a file channel.
|
BlockChannelWriterWithCallback<T> | |
BufferFileReader | |
BufferFileSegmentReader | |
BufferFileWriter | |
BulkBlockChannelReader | |
FileIOChannel |
A Channel represents a collection of files that belong logically to the same resource.
|
RequestDoneCallback<T> |
Callback to be executed on completion of an asynchronous I/O request.
|
Class | Description |
---|---|
AbstractChannelReaderInputView |
A
DataInputView that is backed by a FileIOChannel ,
making it effectively a data input stream. |
AbstractChannelWriterOutputView |
A
DataOutputView that is backed by a FileIOChannel ,
making it effectively a data output stream. |
AbstractFileIOChannel | |
AsynchronousBlockReader |
A reader that reads data in blocks from a file channel.
|
AsynchronousBlockWriter | |
AsynchronousBlockWriterWithCallback |
An asynchronous implementation of the
BlockChannelWriterWithCallback that queues I/O
requests and calls a callback once they have been handled. |
AsynchronousBufferFileReader | |
AsynchronousBufferFileSegmentReader | |
AsynchronousBufferFileWriter | |
AsynchronousBulkBlockReader | |
AsynchronousFileIOChannel<T,R extends org.apache.flink.runtime.io.disk.iomanager.IORequest> |
A base class for readers and writers that accept read or write requests for whole blocks.
|
BufferFileChannelReader |
Helper class to read
Buffer s from files into objects. |
ChannelReaderInputView |
A
DataInputView that is backed by a BlockChannelReader , making it effectively a data input stream. |
ChannelWriterOutputView |
A
DataOutputView that is backed by a BlockChannelWriter , making it effectively a data output stream. |
FileIOChannel.Enumerator |
An enumerator for channels that logically belong together.
|
FileIOChannel.ID |
An ID identifying an underlying file channel.
|
FileSegment | |
HeaderlessChannelReaderInputView |
A
DataInputView that is backed by a BlockChannelReader , making it effectively a data input stream. |
IOManager |
The facade for the provided I/O manager services.
|
IOManagerAsync |
A version of the
IOManager that uses asynchronous I/O. |
QueuingCallback<T> |
A
RequestDoneCallback that adds the memory segments to a blocking queue. |
RequestQueue<E> |
A
LinkedBlockingQueue that is extended with closing methods. |
SynchronousBufferFileReader |
A synchronous
BufferFileReader implementation. |
SynchronousFileIOChannel |
A base class for synchronous readers and writers.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.