Package | Description |
---|---|
alluxio.client.block | |
alluxio.client.block.stream |
Modifier and Type | Method and Description |
---|---|
Pair<WorkerNetAddress,BlockInStream.BlockInStreamSource> |
AlluxioBlockStore.getDataSourceAndType(BlockInfo info,
URIStatus status,
BlockLocationPolicy policy,
Map<WorkerNetAddress,Long> failedWorkers)
Gets the data source and type of data source of a block.
|
Modifier and Type | Method and Description |
---|---|
BlockInStream.BlockInStreamSource |
BlockInStream.getSource() |
static BlockInStream.BlockInStreamSource |
BlockInStream.BlockInStreamSource.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static BlockInStream.BlockInStreamSource[] |
BlockInStream.BlockInStreamSource.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static BlockInStream |
BlockInStream.create(FileSystemContext context,
BlockInfo info,
WorkerNetAddress dataSource,
BlockInStream.BlockInStreamSource dataSourceType,
InStreamOptions options)
Creates a
BlockInStream . |
static BlockInStream |
BlockInStream.createRemoteBlockInStream(FileSystemContext context,
long blockId,
WorkerNetAddress address,
BlockInStream.BlockInStreamSource blockSource,
long blockSize,
Protocol.OpenUfsBlockOptions ufsOptions)
Creates a
BlockInStream to read from a specific remote server. |
Constructor and Description |
---|
BlockInStream(DataReader.Factory dataReaderFactory,
AlluxioConfiguration conf,
WorkerNetAddress address,
BlockInStream.BlockInStreamSource blockSource,
long id,
long length)
Creates an instance of
BlockInStream . |
Copyright © 2023. All Rights Reserved.