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 |
DefaultBlockWorker.createBlockReader(BlockReadRequest request) |
BlockReader |
BlockWorker.createBlockReader(BlockReadRequest request)
Creates the block reader to read from Alluxio block or UFS block.
|
BlockReader |
DefaultBlockWorker.createUfsBlockReader(long sessionId,
long blockId,
long offset,
boolean positionShort,
Protocol.OpenUfsBlockOptions options) |
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 |
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,
String user)
Creates a block reader that reads from UFS and optionally caches the block to the Alluxio
block store.
|
Modifier and Type | Class and Description |
---|---|
class |
DelegatingBlockReader
An delegating reader class.
|
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 |
---|---|
BlockReader |
DelegatingBlockReader.getDelegate() |
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.
|
Constructor and Description |
---|
DelegatingBlockReader(BlockReader blockReader,
Closeable closeable)
Default constructor for the abstract reader implementations.
|
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.