| Package | Description |
|---|---|
| alluxio.client.block | |
| alluxio.client.block.stream |
| Modifier and Type | Method and Description |
|---|---|
Pair<WorkerNetAddress,BlockInStream.BlockInStreamSource> |
BlockStoreClient.getDataSourceAndType(BlockInfo info,
URIStatus status,
BlockLocationPolicy policy,
java.util.Map<WorkerNetAddress,java.lang.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(java.lang.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,
WorkerNetAddress address,
BlockInStream.BlockInStreamSource blockSource,
long id,
long length)
Creates an instance of
BlockInStream. |
Copyright © 2022. All Rights Reserved.