Package | Description |
---|---|
org.apache.flink.runtime.io.disk.iomanager | |
org.apache.flink.table.runtime.io |
Modifier and Type | Interface and Description |
---|---|
interface |
BlockChannelWriter<T>
A writer that writes data in blocks to a file channel.
|
interface |
BufferFileWriter |
Modifier and Type | Class and Description |
---|---|
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 |
AsynchronousBufferFileWriter |
Modifier and Type | Method and Description |
---|---|
abstract BlockChannelWriterWithCallback<MemorySegment> |
IOManager.createBlockChannelWriter(FileIOChannel.ID channelID,
RequestDoneCallback<MemorySegment> callback)
Creates a block channel writer that writes to the given channel.
|
BlockChannelWriterWithCallback<MemorySegment> |
IOManagerAsync.createBlockChannelWriter(FileIOChannel.ID channelID,
RequestDoneCallback<MemorySegment> callback) |
Modifier and Type | Class and Description |
---|---|
class |
CompressedBlockChannelWriter
Compressed block channel writer provides a scenario where MemorySegment must be maintained.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.