Package | Description |
---|---|
alluxio.client.block | |
alluxio.client.block.stream | |
alluxio.client.file |
Modifier and Type | Method and Description |
---|---|
BlockInStream |
AlluxioBlockStore.getInStream(BlockInfo info,
InStreamOptions options,
Map<WorkerNetAddress,Long> failedWorkers)
|
BlockInStream |
AlluxioBlockStore.getInStream(long blockId,
InStreamOptions options)
Gets a stream to read the data of a block.
|
BlockInStream |
AlluxioBlockStore.getInStream(long blockId,
InStreamOptions options,
Map<WorkerNetAddress,Long> failedWorkers)
Gets a stream to read the data of a block.
|
Modifier and Type | Method and Description |
---|---|
static BlockInStream |
BlockInStream.create(FileSystemContext context,
BlockInfo info,
WorkerNetAddress dataSource,
BlockInStream.BlockInStreamSource dataSourceType,
InStreamOptions options)
Creates a
BlockInStream . |
Constructor and Description |
---|
Factory(BlockWorker blockWorker,
long blockId,
long chunkSize,
InStreamOptions options)
Creates an instance of
BlockWorkerDataReader.Factory . |
Factory(FileSystemContext context,
WorkerNetAddress address,
long blockId,
long localReaderChunkSize,
InStreamOptions options)
Creates an instance of
LocalFileDataReader.Factory . |
Constructor and Description |
---|
AlluxioFileInStream(URIStatus status,
InStreamOptions options,
FileSystemContext context) |
Copyright © 2023. All Rights Reserved.