Package | Description |
---|---|
alluxio.worker.block | |
alluxio.worker.block.meta |
Modifier and Type | Method and Description |
---|---|
void |
DefaultBlockWorker.abortBlock(long sessionId,
long blockId) |
void |
TieredBlockStore.abortBlock(long sessionId,
long blockId) |
void |
BlockWorker.abortBlock(long sessionId,
long blockId)
Aborts the temporary block created by the session.
|
void |
BlockStore.abortBlock(long sessionId,
long blockId)
Aborts a temporary block.
|
void |
DefaultBlockWorker.commitBlock(long sessionId,
long blockId,
boolean pinOnCreate) |
void |
TieredBlockStore.commitBlock(long sessionId,
long blockId,
boolean pinOnCreate) |
void |
BlockWorker.commitBlock(long sessionId,
long blockId,
boolean pinOnCreate)
Commits a block to Alluxio managed space.
|
void |
BlockStore.commitBlock(long sessionId,
long blockId,
boolean pinOnCreate)
Commits a temporary block to the local store.
|
void |
DefaultBlockWorker.freeSpace(long sessionId,
long availableBytes,
String tierAlias) |
void |
BlockWorker.freeSpace(long sessionId,
long availableBytes,
String tierAlias)
Frees space to make a specific amount of bytes available in a best-effort way in the tier.
|
BlockMeta |
DefaultBlockWorker.getBlockMeta(long sessionId,
long blockId,
long lockId) |
BlockMeta |
TieredBlockStore.getBlockMeta(long sessionId,
long blockId,
long lockId) |
BlockMeta |
BlockWorker.getBlockMeta(long sessionId,
long blockId,
long lockId)
Gets the metadata of a specific block from local storage.
|
BlockMeta |
BlockStore.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.
|
BlockWriter |
DefaultBlockWorker.getTempBlockWriterRemote(long sessionId,
long blockId) |
BlockWriter |
BlockWorker.getTempBlockWriterRemote(long sessionId,
long blockId)
Opens a
BlockWriter for an existing temporary block. |
void |
TieredBlockStore.moveBlock(long sessionId,
long blockId,
BlockStoreLocation newLocation) |
void |
BlockStore.moveBlock(long sessionId,
long blockId,
BlockStoreLocation newLocation)
Moves an existing block to a new location.
|
void |
TieredBlockStore.moveBlock(long sessionId,
long blockId,
BlockStoreLocation oldLocation,
BlockStoreLocation newLocation) |
void |
BlockStore.moveBlock(long sessionId,
long blockId,
BlockStoreLocation oldLocation,
BlockStoreLocation newLocation)
Moves an existing block to a new location.
|
void |
DefaultBlockWorker.moveBlock(long sessionId,
long blockId,
String tierAlias) |
void |
BlockWorker.moveBlock(long sessionId,
long blockId,
String tierAlias)
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.
|
String |
DefaultBlockWorker.readBlock(long sessionId,
long blockId,
long lockId) |
String |
BlockWorker.readBlock(long sessionId,
long blockId,
long lockId)
Gets the path to the block file in local storage.
|
BlockReader |
DefaultBlockWorker.readBlockRemote(long sessionId,
long blockId,
long lockId) |
BlockReader |
BlockWorker.readBlockRemote(long sessionId,
long blockId,
long lockId)
Gets the block reader for the block.
|
void |
DefaultBlockWorker.removeBlock(long sessionId,
long blockId) |
void |
TieredBlockStore.removeBlock(long sessionId,
long blockId) |
void |
BlockWorker.removeBlock(long sessionId,
long blockId)
Frees a block from Alluxio managed space.
|
void |
BlockStore.removeBlock(long sessionId,
long blockId)
Removes an existing block.
|
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 |
StorageDir.resizeTempBlockMeta(TempBlockMeta tempBlockMeta,
long newSize)
Changes the size of a temp block.
|
Copyright © 2023. All Rights Reserved.