Package | Description |
---|---|
alluxio.worker.block | |
alluxio.worker.block.meta |
Modifier and Type | Method and Description |
---|---|
void |
TieredBlockStore.abortBlock(long sessionId,
long blockId) |
void |
DefaultBlockWorker.abortBlock(long sessionId,
long blockId) |
void |
BlockStore.abortBlock(long sessionId,
long blockId)
Aborts a temporary block.
|
void |
BlockWorker.abortBlock(long sessionId,
long blockId)
Aborts the temporary block created by the session.
|
void |
TieredBlockStore.commitBlock(long sessionId,
long blockId,
boolean pinOnCreate) |
void |
DefaultBlockWorker.commitBlock(long sessionId,
long blockId,
boolean pinOnCreate) |
void |
BlockStore.commitBlock(long sessionId,
long blockId,
boolean pinOnCreate)
Commits a temporary block to the local store.
|
void |
BlockWorker.commitBlock(long sessionId,
long blockId,
boolean pinOnCreate)
Commits a block to Alluxio managed space.
|
long |
TieredBlockStore.commitBlockLocked(long sessionId,
long blockId,
boolean pinOnCreate) |
long |
BlockStore.commitBlockLocked(long sessionId,
long blockId,
boolean pinOnCreate)
Similar to
BlockStore.commitBlock(long, long, boolean) . |
BlockWriter |
DefaultBlockWorker.createBlockWriter(long sessionId,
long blockId) |
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, java.lang.String, long) . |
BlockMeta |
TieredBlockStore.getBlockMeta(long sessionId,
long blockId,
long lockId) |
BlockMeta |
DefaultBlockWorker.getBlockMeta(long sessionId,
long blockId,
long lockId) |
BlockMeta |
BlockStore.getBlockMeta(long sessionId,
long blockId,
long lockId)
Gets the metadata of a specific block from local storage.
|
BlockMeta |
BlockWorker.getBlockMeta(long sessionId,
long blockId,
long lockId)
Gets the metadata of a specific block from local storage.
|
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.
|
BlockWriter |
TieredBlockStore.getBlockWriter(long sessionId,
long blockId) |
BlockWriter |
BlockStore.getBlockWriter(long sessionId,
long blockId)
Creates a writer to write data to a temp block.
|
void |
TieredBlockStore.moveBlock(long sessionId,
long blockId,
AllocateOptions moveOptions) |
void |
BlockStore.moveBlock(long sessionId,
long blockId,
AllocateOptions moveOptions)
Moves an existing block to a new location.
|
void |
TieredBlockStore.moveBlock(long sessionId,
long blockId,
BlockStoreLocation oldLocation,
AllocateOptions moveOptions) |
void |
BlockStore.moveBlock(long sessionId,
long blockId,
BlockStoreLocation oldLocation,
AllocateOptions moveOptions)
Moves an existing block to a new location.
|
void |
DefaultBlockWorker.moveBlock(long sessionId,
long blockId,
int tier) |
void |
BlockWorker.moveBlock(long sessionId,
long blockId,
int tier)
Moves a block from its current location to a target location, currently only tier level moves
are supported.
|
void |
DefaultBlockWorker.moveBlockToMedium(long sessionId,
long blockId,
String mediumType) |
void |
BlockWorker.moveBlockToMedium(long sessionId,
long blockId,
String mediumType)
Moves a block from its current location to a target location, with a specific medium type.
|
void |
TieredBlockStore.removeBlock(long sessionId,
long blockId) |
void |
DefaultBlockWorker.removeBlock(long sessionId,
long blockId) |
void |
BlockStore.removeBlock(long sessionId,
long blockId)
Removes an existing block.
|
void |
BlockWorker.removeBlock(long sessionId,
long blockId)
Frees a block from Alluxio managed space.
|
void |
TieredBlockStore.removeBlock(long sessionId,
long blockId,
BlockStoreLocation location) |
void |
BlockStore.removeBlock(long sessionId,
long blockId,
BlockStoreLocation location)
Removes an existing block.
|
void |
BlockMetadataManager.resizeTempBlockMeta(TempBlockMeta tempBlockMeta,
long newSize)
Modifies the size of a temp block.
|
void |
BlockLockManager.validateLock(long sessionId,
long blockId,
long lockId)
Validates the lock is hold by the given session for the given block.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultStorageDir.resizeTempBlockMeta(TempBlockMeta tempBlockMeta,
long newSize) |
void |
StorageDir.resizeTempBlockMeta(TempBlockMeta tempBlockMeta,
long newSize)
Changes the size of a temp block.
|
Copyright © 2023. All Rights Reserved.