Package | Description |
---|---|
org.apache.flink.runtime.io.disk.iomanager |
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 |
---|---|
BlockChannelWriterWithCallback<MemorySegment> |
IOManagerAsync.createBlockChannelWriter(FileIOChannel.ID channelID,
RequestDoneCallback<MemorySegment> callback) |
abstract BlockChannelWriterWithCallback<MemorySegment> |
IOManager.createBlockChannelWriter(FileIOChannel.ID channelID,
RequestDoneCallback<MemorySegment> callback)
Creates a block channel writer that writes to the given channel.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.