| Package | Description |
|---|---|
| alluxio.client.block | |
| alluxio.client.block.stream | |
| alluxio.client.file |
| Modifier and Type | Method and Description |
|---|---|
BlockInStream |
BlockStoreClient.getInStream(BlockInfo info,
InStreamOptions options,
java.util.Map<WorkerNetAddress,java.lang.Long> failedWorkers)
|
BlockInStream |
BlockStoreClient.getInStream(long blockId,
InStreamOptions options)
Gets a stream to read the data of a block.
|
BlockInStream |
BlockStoreClient.getInStream(long blockId,
InStreamOptions options,
java.util.Map<WorkerNetAddress,java.lang.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 © 2022. All Rights Reserved.