Package | Description |
---|---|
alluxio.worker.block | |
alluxio.worker.block.meta | |
alluxio.worker.page |
Modifier and Type | Method and Description |
---|---|
void |
BlockMetadataManager.commitTempBlockMeta(TempBlockMeta tempBlockMeta)
Commits a temp block.
|
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.
|
String |
MonoBlockStore.createBlock(long sessionId,
long blockId,
int tier,
CreateBlockOptions createBlockOptions) |
String |
DefaultBlockWorker.createBlock(long sessionId,
long blockId,
int tier,
CreateBlockOptions createBlockOptions) |
String |
BlockWorker.createBlock(long sessionId,
long blockId,
int tier,
CreateBlockOptions createBlockOptions)
Creates a block in Alluxio managed space.
|
String |
BlockStore.createBlock(long sessionId,
long blockId,
int tier,
CreateBlockOptions createBlockOptions)
Creates a block in Alluxio managed space.
|
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 |
TieredBlockStore.moveBlock(long sessionId,
long blockId,
AllocateOptions moveOptions) |
void |
MonoBlockStore.moveBlock(long sessionId,
long blockId,
AllocateOptions moveOptions) |
void |
LocalBlockStore.moveBlock(long sessionId,
long blockId,
AllocateOptions moveOptions)
Moves an existing block to a new location.
|
void |
BlockStore.moveBlock(long sessionId,
long blockId,
AllocateOptions moveOptions)
Moves an existing block to a new location.
|
BlockMeta |
BlockMetadataManager.moveBlockMeta(BlockMeta blockMeta,
TempBlockMeta tempBlockMeta)
Moves an existing block to another location currently hold by a temp block.
|
void |
TieredBlockStore.requestSpace(long sessionId,
long blockId,
long additionalBytes) |
void |
MonoBlockStore.requestSpace(long sessionId,
long blockId,
long additionalBytes) |
void |
DefaultBlockWorker.requestSpace(long sessionId,
long blockId,
long additionalBytes) |
void |
LocalBlockStore.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 |
BlockStore.requestSpace(long sessionId,
long blockId,
long additionalBytes)
Requests to increase the size of a temp block.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultStorageDir.addBlockMeta(BlockMeta blockMeta) |
void |
StorageDir.addBlockMeta(BlockMeta blockMeta)
Adds the metadata of a new block into this storage dir.
|
static StorageDir |
DefaultStorageDir.newStorageDir(StorageTier tier,
int dirIndex,
long capacityBytes,
long reservedBytes,
String dirPath,
String dirMedium)
Factory method to create
StorageDir . |
static StorageTier |
DefaultStorageTier.newStorageTier(String tierAlias,
int tierOrdinal,
boolean isMultiTier)
Factory method to create
StorageTier . |
Modifier and Type | Method and Description |
---|---|
String |
PagedBlockStore.createBlock(long sessionId,
long blockId,
int tier,
CreateBlockOptions createBlockOptions) |
void |
PagedBlockStore.moveBlock(long sessionId,
long blockId,
AllocateOptions moveOptions) |
void |
PagedBlockStore.requestSpace(long sessionId,
long blockId,
long additionalBytes) |
Copyright © 2023. All Rights Reserved.