Package | Description |
---|---|
alluxio.worker.block | |
alluxio.worker.block.io | |
alluxio.worker.grpc | |
alluxio.worker.page |
Modifier and Type | Method and Description |
---|---|
BlockWriter |
TieredBlockStore.createBlockWriter(long sessionId,
long blockId) |
BlockWriter |
LocalBlockStore.createBlockWriter(long sessionId,
long blockId)
Creates a writer to write data to a temp block.
|
BlockWriter |
MonoBlockStore.createBlockWriter(long sessionId,
long blockId) |
BlockWriter |
DefaultBlockWorker.createBlockWriter(long sessionId,
long blockId) |
BlockWriter |
BlockStore.createBlockWriter(long sessionId,
long blockId)
Creates a
BlockWriter for an existing temporary block which is already created by
BlockStore.createBlock(long, long, int, alluxio.worker.block.CreateBlockOptions) . |
BlockWriter |
BlockWorker.createBlockWriter(long sessionId,
long blockId)
Creates a
BlockWriter for an existing temporary block which is already created by
BlockWorker.createBlock(long, long, int, alluxio.worker.block.CreateBlockOptions) . |
Modifier and Type | Class and Description |
---|---|
class |
LocalFileBlockWriter
This class provides write access to a temp block data file locally stored in managed storage.
|
class |
StoreBlockWriter
A local block writer used by block store.
|
Modifier and Type | Method and Description |
---|---|
static void |
BlockStreamTracker.writerClosed(BlockWriter writer,
BlockStoreLocation location)
Called when an existing block writer is closed.
|
static void |
BlockStreamTracker.writerOpened(BlockWriter writer,
BlockStoreLocation location)
Called with a new block writer.
|
Modifier and Type | Method and Description |
---|---|
BlockWriter |
BlockWriteRequestContext.getBlockWriter() |
Modifier and Type | Method and Description |
---|---|
void |
BlockWriteRequestContext.setBlockWriter(BlockWriter blockWriter) |
Modifier and Type | Class and Description |
---|---|
class |
PagedBlockWriter
A paged implementation of BlockWriter interface.
|
Modifier and Type | Method and Description |
---|---|
BlockWriter |
PagedBlockStore.createBlockWriter(long sessionId,
long blockId) |
Copyright © 2023. All Rights Reserved.