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 |
BlockMetadataManager.abortTempBlockMeta(TempBlockMeta tempBlockMeta)
Aborts a temp block.
|
void |
TieredBlockStore.accessBlock(long sessionId,
long blockId) |
void |
DefaultBlockWorker.accessBlock(long sessionId,
long blockId) |
void |
BlockStore.accessBlock(long sessionId,
long blockId)
Notifies the block store that a block was accessed so the block store could update accordingly
the registered listeners such as evictor and allocator on block access.
|
void |
BlockWorker.accessBlock(long sessionId,
long blockId)
Access the block for a given 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) . |
void |
BlockMetadataManager.commitTempBlockMeta(TempBlockMeta tempBlockMeta)
Commits a temp block.
|
BlockReader |
DefaultBlockWorker.createBlockReader(BlockReadRequest request) |
BlockReader |
BlockWorker.createBlockReader(BlockReadRequest request)
Creates the block reader to read from Alluxio block or UFS block.
|
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) . |
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.
|
BlockMeta |
BlockMetadataEvictorView.getBlockMeta(long blockId)
Returns null if block is pinned or currently being locked, otherwise returns
BlockMetadataManager.getBlockMeta(long) . |
BlockMeta |
BlockMetadataManager.getBlockMeta(long blockId)
Gets the metadata of a block given its block id.
|
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.
|
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.
|
BlockWriter |
TieredBlockStore.getBlockWriter(long sessionId,
long blockId) |
BlockWriter |
BlockStore.getBlockWriter(long sessionId,
long blockId)
Creates a writer to write data to a temp block.
|
TempBlockMeta |
BlockMetadataManager.getTempBlockMeta(long blockId)
Gets the metadata of a temp block.
|
BlockMeta |
TieredBlockStore.getVolatileBlockMeta(long blockId) |
BlockMeta |
DefaultBlockWorker.getVolatileBlockMeta(long blockId) |
BlockMeta |
BlockStore.getVolatileBlockMeta(long blockId)
Gets the metadata of a block given its block id or throws
BlockDoesNotExistException . |
BlockMeta |
BlockWorker.getVolatileBlockMeta(long blockId)
Gets the metadata of a block given its blockId or throws IOException.
|
long |
TieredBlockStore.lockBlock(long sessionId,
long blockId) |
long |
BlockStore.lockBlock(long sessionId,
long blockId)
Locks an existing block and guards subsequent reads on this 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.
|
BlockMeta |
BlockMetadataManager.moveBlockMeta(BlockMeta blockMeta,
BlockStoreLocation newLocation)
Deprecated.
As of version 0.8. Use
BlockMetadataManager.moveBlockMeta(BlockMeta, TempBlockMeta) instead. |
BlockMeta |
BlockMetadataManager.moveBlockMeta(BlockMeta blockMeta,
TempBlockMeta tempBlockMeta)
Moves an existing block to another location currently hold by a temp block.
|
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.removeBlockMeta(BlockMeta block)
Removes the metadata of a specific block.
|
void |
TieredBlockStore.requestSpace(long sessionId,
long blockId,
long additionalBytes) |
void |
DefaultBlockWorker.requestSpace(long sessionId,
long blockId,
long additionalBytes) |
void |
BlockStore.requestSpace(long sessionId,
long blockId,
long additionalBytes)
Requests to increase the size of a temp block.
|
void |
BlockWorker.requestSpace(long sessionId,
long blockId,
long additionalBytes)
Request an amount of space for a block in its storage directory.
|
void |
BlockMetadataManager.swapBlocks(BlockMeta blockMeta1,
BlockMeta blockMeta2)
Swaps location of two blocks in metadata.
|
void |
BlockLockManager.unlockBlock(long lockId)
Releases the lock with the specified lock id.
|
void |
TieredBlockStore.unlockBlock(long lockId) |
void |
DefaultBlockWorker.unlockBlock(long lockId) |
void |
BlockStore.unlockBlock(long lockId)
Releases an acquired block lock based on a lockId (returned by
BlockStore.lockBlock(long, long) . |
void |
BlockWorker.unlockBlock(long lockId)
Releases the lock with the specified lock id.
|
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 |
---|---|
BlockMeta |
DefaultStorageDir.getBlockMeta(long blockId) |
BlockMeta |
StorageDir.getBlockMeta(long blockId)
Gets the
BlockMeta from this storage dir by its block id. |
void |
DefaultStorageDir.removeBlockMeta(BlockMeta blockMeta) |
void |
StorageDir.removeBlockMeta(BlockMeta blockMeta)
Removes a block from this storage dir.
|
void |
DefaultStorageDir.removeTempBlockMeta(TempBlockMeta tempBlockMeta) |
void |
StorageDir.removeTempBlockMeta(TempBlockMeta tempBlockMeta)
Removes a temp block from this storage dir.
|
Copyright © 2023. All Rights Reserved.