Package | Description |
---|---|
alluxio.worker.block | |
alluxio.worker.block.io | |
alluxio.worker.block.meta | |
alluxio.worker.page |
Modifier and Type | Method and Description |
---|---|
TempBlockMeta |
TieredBlockStore.createBlock(long sessionId,
long blockId,
AllocateOptions options) |
TempBlockMeta |
LocalBlockStore.createBlock(long sessionId,
long blockId,
AllocateOptions options)
Creates the metadata of a new block and assigns a temporary path (e.g., a subdir of the final
location named after session id) to store its data.
|
Modifier and Type | Method and Description |
---|---|
List<TempBlockMeta> |
BlockMetadataManager.getSessionTempBlocks(long sessionId)
Gets all the temporary blocks associated with a session, empty list is returned if the session
has no temporary blocks.
|
Optional<TempBlockMeta> |
MonoBlockStore.getTempBlockMeta(long blockId) |
Optional<TempBlockMeta> |
TieredBlockStore.getTempBlockMeta(long blockId) |
Optional<TempBlockMeta> |
LocalBlockStore.getTempBlockMeta(long blockId)
Gets the temp metadata of a specific block from local storage.
|
Optional<TempBlockMeta> |
BlockMetadataManager.getTempBlockMeta(long blockId)
Gets the metadata of a temp block.
|
Optional<TempBlockMeta> |
BlockStore.getTempBlockMeta(long blockId)
Gets the temp metadata of a specific block from local storage.
|
Modifier and Type | Method and Description |
---|---|
void |
BlockMetadataManager.abortTempBlockMeta(TempBlockMeta tempBlockMeta)
Aborts a temp block.
|
void |
BlockMetadataManager.addTempBlockMeta(TempBlockMeta tempBlockMeta)
Adds a temp block.
|
void |
BlockMetadataManager.commitTempBlockMeta(TempBlockMeta tempBlockMeta)
Commits a temp block.
|
BlockMeta |
BlockMetadataManager.moveBlockMeta(BlockMeta blockMeta,
TempBlockMeta tempBlockMeta)
Moves an existing block to another location currently hold by a temp block.
|
void |
BlockMetadataManager.resizeTempBlockMeta(TempBlockMeta tempBlockMeta,
long newSize)
Modifies the size of a temp block.
|
Constructor and Description |
---|
StoreBlockWriter(TempBlockMeta blockMeta)
Creates new block writer for block store.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultTempBlockMeta
Represents the metadata of an uncommitted block in Alluxio managed storage.
|
Modifier and Type | Method and Description |
---|---|
TempBlockMeta |
StorageDirView.createTempBlockMeta(long sessionId,
long blockId,
long initialBlockSize)
Creates a
TempBlockMeta given sessionId, blockId, and initialBlockSize. |
Modifier and Type | Method and Description |
---|---|
List<TempBlockMeta> |
DefaultStorageDir.getSessionTempBlocks(long sessionId) |
List<TempBlockMeta> |
StorageDir.getSessionTempBlocks(long sessionId)
Gets the temporary blocks associated with a session in this
StorageDir , an empty list
is returned if the session has no temporary blocks in this StorageDir . |
Optional<TempBlockMeta> |
DefaultStorageDir.getTempBlockMeta(long blockId) |
Optional<TempBlockMeta> |
StorageDir.getTempBlockMeta(long blockId)
Gets the
TempBlockMeta from this storage dir by its block id. |
Modifier and Type | Method and Description |
---|---|
void |
DefaultStorageDir.addTempBlockMeta(TempBlockMeta tempBlockMeta) |
void |
StorageDir.addTempBlockMeta(TempBlockMeta tempBlockMeta)
Adds the metadata of a new block into this storage dir.
|
void |
DefaultStorageDir.removeTempBlockMeta(TempBlockMeta tempBlockMeta) |
void |
StorageDir.removeTempBlockMeta(TempBlockMeta tempBlockMeta)
Removes a temp block from this storage dir.
|
void |
DefaultStorageDir.resizeTempBlockMeta(TempBlockMeta tempBlockMeta,
long newSize) |
void |
StorageDir.resizeTempBlockMeta(TempBlockMeta tempBlockMeta,
long newSize)
Changes the size of a temp block.
|
Constructor and Description |
---|
DefaultBlockMeta(TempBlockMeta tempBlock)
Creates a new instance of
DefaultBlockMeta from DefaultTempBlockMeta . |
Modifier and Type | Method and Description |
---|---|
Optional<TempBlockMeta> |
PagedBlockStore.getTempBlockMeta(long blockId) |
Copyright © 2023. All Rights Reserved.