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 |
BlockWorker.closeUfsBlock(long sessionId,
long blockId)
Closes a UFS block for a client 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.
|
void |
TieredBlockStore.freeSpace(long sessionId,
long minContiguousBytes,
long minAvailableBytes,
BlockStoreLocation location)
Free space is the entry for immediate block deletion in order to open up space for
new or ongoing blocks.
|
void |
BlockStore.freeSpace(long sessionId,
long minContigiousBytes,
long minAvailableBytes,
BlockStoreLocation location)
Frees space to make a specific amount of bytes available in the location.
|
void |
DefaultBlockWorker.freeSpace(long sessionId,
long availableBytes,
String tierAlias) |
void |
BlockWorker.freeSpace(long sessionId,
long availableBytes,
String tierAlias)
Deprecated.
to be removed at Alluxio 3.0
Frees space to make a specific amount of bytes available in a best-effort way in the tier. The
implementation should try to free at least 1 byte from the worker, otherwise a
WorkerOutOfSpaceException should be thrown if no space is available. |
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)
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.
|
BlockWriter |
DefaultBlockWorker.getTempBlockWriterRemote(long sessionId,
long blockId) |
BlockWriter |
BlockWorker.getTempBlockWriterRemote(long sessionId,
long blockId)
Opens a
BlockWriter for an existing temporary block for non short-circuit writes or
cache requests. |
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 |
DefaultBlockWorker.lockBlock(long sessionId,
long blockId) |
long |
BlockStore.lockBlock(long sessionId,
long blockId)
Locks an existing block and guards subsequent reads on this block.
|
long |
BlockWorker.lockBlock(long sessionId,
long blockId)
Obtains a read lock the 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,
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.
|
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.
|
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 for non short-circuit reads.
|
BlockReader |
DefaultBlockWorker.readUfsBlock(long sessionId,
long blockId,
long offset,
boolean positionShort) |
BlockReader |
BlockWorker.readUfsBlock(long sessionId,
long blockId,
long offset,
boolean positionShort)
Gets a block reader to read a UFS block for non short-circuit reads.
|
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 |
TieredBlockStore.unlockBlock(long lockId) |
void |
BlockLockManager.unlockBlock(long lockId)
Releases the lock with the specified lock id.
|
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 |
StorageDir.getBlockMeta(long blockId)
Gets the
BlockMeta from this storage dir by its block id. |
void |
StorageDir.removeBlockMeta(BlockMeta blockMeta)
Removes a block from this storage dir.
|
void |
StorageDir.removeTempBlockMeta(TempBlockMeta tempBlockMeta)
Removes a temp block from this storage dir.
|
Copyright © 2023. All Rights Reserved.