Package | Description |
---|---|
org.apache.flink.runtime.io.disk.iomanager |
Modifier and Type | Class and Description |
---|---|
class |
AsynchronousBulkBlockReader |
Modifier and Type | Method and Description |
---|---|
abstract BulkBlockChannelReader |
IOManager.createBulkBlockChannelReader(FileIOChannel.ID channelID,
List<MemorySegment> targetSegments,
int numBlocks)
Creates a block channel reader that reads all blocks from the given channel directly in one bulk.
|
BulkBlockChannelReader |
IOManagerAsync.createBulkBlockChannelReader(FileIOChannel.ID channelID,
List<MemorySegment> targetSegments,
int numBlocks)
Creates a block channel reader that reads all blocks from the given channel directly in one bulk.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.