Package | Description |
---|---|
org.apache.flink.runtime.io.disk.iomanager | |
org.apache.flink.table.runtime.io | |
org.apache.flink.table.runtime.operators.sort | |
org.apache.flink.table.runtime.util |
Modifier and Type | Interface and Description |
---|---|
interface |
BlockChannelReader<T>
A reader that reads data in blocks from a file channel.
|
interface |
BlockChannelWriter<T>
A writer that writes data in blocks to a file channel.
|
interface |
BlockChannelWriterWithCallback<T> |
interface |
BufferFileReader |
interface |
BufferFileSegmentReader |
interface |
BufferFileWriter |
interface |
BulkBlockChannelReader |
Modifier and Type | Class and Description |
---|---|
class |
AbstractFileIOChannel |
class |
AsynchronousBlockReader
A reader that reads data in blocks from a file channel.
|
class |
AsynchronousBlockWriter |
class |
AsynchronousBlockWriterWithCallback
An asynchronous implementation of the
BlockChannelWriterWithCallback that queues I/O
requests and calls a callback once they have been handled. |
class |
AsynchronousBufferFileReader |
class |
AsynchronousBufferFileSegmentReader |
class |
AsynchronousBufferFileWriter |
class |
AsynchronousBulkBlockReader |
class |
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.
|
class |
SynchronousBufferFileReader
A synchronous
BufferFileReader implementation. |
class |
SynchronousFileIOChannel
A base class for synchronous readers and writers.
|
Modifier and Type | Method and Description |
---|---|
FileIOChannel |
ChannelReaderInputView.getChannel() |
abstract FileIOChannel |
AbstractChannelWriterOutputView.getChannel()
Get the underlying channel.
|
abstract FileIOChannel |
AbstractChannelReaderInputView.getChannel()
Get the underlying channel.
|
Modifier and Type | Class and Description |
---|---|
class |
CompressedBlockChannelReader
Compressed block channel reader provides a scenario where MemorySegment must be maintained.
|
class |
CompressedBlockChannelWriter
Compressed block channel writer provides a scenario where MemorySegment must be maintained.
|
Modifier and Type | Method and Description |
---|---|
FileIOChannel |
HeaderlessChannelWriterOutputView.getChannel() |
FileIOChannel |
CompressedHeaderlessChannelReaderInputView.getChannel() |
FileIOChannel |
CompressedHeaderlessChannelWriterOutputView.getChannel() |
Modifier and Type | Method and Description |
---|---|
void |
SpillChannelManager.addOpenChannels(List<FileIOChannel> toOpen)
Open File channels.
|
BinaryMergeIterator<Entry> |
AbstractBinaryExternalMerger.getMergingIterator(List<ChannelWithMeta> channelIDs,
List<FileIOChannel> openChannels)
Returns an iterator that iterates over the merged result from all given channels.
|
Modifier and Type | Method and Description |
---|---|
static AbstractChannelReaderInputView |
FileChannelUtil.createInputView(IOManager ioManager,
ChannelWithMeta channel,
List<FileIOChannel> channels,
boolean compressionEnable,
BlockCompressionFactory compressionCodecFactory,
int compressionBlockSize,
int segmentSize) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.