Package | Description |
---|---|
alluxio.worker.block | |
alluxio.worker.block.io | |
alluxio.worker.dora | |
alluxio.worker.grpc | |
alluxio.worker.netty | |
alluxio.worker.s3 |
Modifier and Type | Method and Description |
---|---|
BlockReader |
BlockStore.createBlockReader(long sessionId,
long blockId,
long lockId)
Creates a reader of an existing block to read data from this block.
|
BlockReader |
BlockStore.createBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options)
Creates the block reader to read from Alluxio block or UFS block.
|
BlockReader |
BlockWorker.createBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options)
Creates the block reader to read from Alluxio block or UFS block.
|
BlockReader |
BlockStore.createUfsBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options)
Creates a block reader to read a UFS block starting from given block offset.
|
BlockReader |
BlockWorker.createUfsBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options)
Creates a block reader to read a UFS block starting from given block offset.
|
BlockReader |
BlockWorker.readBlockRemote(long sessionId,
long blockId,
long lockId)
Gets the block reader for the block.
|
BlockReader |
BlockWorker.readUfsBlock(long sessionId,
long blockId,
long offset)
Gets a block reader to read a UFS block.
|
Constructor and Description |
---|
BlockReadableChannel(BlockReader reader)
Creates a new channel from a block reader.
|
Modifier and Type | Class and Description |
---|---|
class |
PagedFileReader
Paged file reader.
|
Modifier and Type | Method and Description |
---|---|
BlockReader |
PagedDoraWorker.createFileReader(String fileId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options) |
BlockReader |
DoraWorker.createFileReader(String fileId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options)
Creates the file reader to read from Alluxio dora.
|
Modifier and Type | Method and Description |
---|---|
BlockReader |
BlockReadRequestContext.getBlockReader() |
Modifier and Type | Method and Description |
---|---|
void |
BlockReadRequestContext.setBlockReader(BlockReader blockReader) |
Modifier and Type | Method and Description |
---|---|
BlockReader |
BlockReadRequestContext.getBlockReader() |
Modifier and Type | Method and Description |
---|---|
void |
BlockReadRequestContext.setBlockReader(BlockReader blockReader) |
Modifier and Type | Method and Description |
---|---|
BlockReader |
S3NettyHandler.openBlock(String ufsFullPath,
long offset,
long length)
Gets a
BlockReader according the ufs full path, offset and length. |
Modifier and Type | Method and Description |
---|---|
void |
S3NettyHandler.processMappedResponse(BlockReader blockReader,
long objectSize)
Writes data into netty channel by copying through ByteBuf.
|
Copyright © 2023. All Rights Reserved.