Package | Description |
---|---|
alluxio.worker.block | |
alluxio.worker.block.io | |
alluxio.worker.grpc |
Modifier and Type | Class and Description |
---|---|
class |
RemoteBlockReader
Reads a block from a remote worker node.
|
class |
UnderFileSystemBlockReader
This class implements a
BlockReader to read a block directly from UFS, and
optionally cache the block to the Alluxio worker if the whole block it is read. |
Modifier and Type | Method and Description |
---|---|
BlockReader |
TieredBlockStore.getBlockReader(long sessionId,
long blockId,
long lockId) |
BlockReader |
BlockStore.getBlockReader(long sessionId,
long blockId,
long lockId)
Creates a reader of an existing block to read data from this block.
|
BlockReader |
UnderFileSystemBlockStore.getBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort)
Creates a block reader that reads from UFS and optionally caches the block to the Alluxio
block store.
|
BlockReader |
BlockWorker.readBlockRemote(long sessionId,
long blockId,
long lockId)
Gets the block reader for the block for non short-circuit reads.
|
BlockReader |
DefaultBlockWorker.readBlockRemote(long sessionId,
long blockId,
long lockId) |
BlockReader |
BlockWorker.readUfsBlock(long sessionId,
long blockId,
long offset,
boolean positionShort)
Gets a block reader to read a UFS block for non short-circuit reads.
|
BlockReader |
DefaultBlockWorker.readUfsBlock(long sessionId,
long blockId,
long offset,
boolean positionShort) |
Modifier and Type | Class and Description |
---|---|
class |
LocalFileBlockReader
This class provides read access to a block data file locally stored in managed storage.
|
class |
StoreBlockReader
A local block reader used by block store.
|
Modifier and Type | Method and Description |
---|---|
static void |
BlockStreamTracker.readerClosed(BlockReader reader,
BlockStoreLocation location)
Called when an existing block reader is closed.
|
static void |
BlockStreamTracker.readerOpened(BlockReader reader,
BlockStoreLocation location)
Called with a new block reader.
|
Modifier and Type | Method and Description |
---|---|
BlockReader |
BlockReadRequestContext.getBlockReader() |
Modifier and Type | Method and Description |
---|---|
void |
BlockReadRequestContext.setBlockReader(BlockReader blockReader) |
Copyright © 2023. All Rights Reserved.