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 |
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.
|
boolean |
UnderFileSystemBlockStore.acquireAccess(long sessionId,
long blockId,
Protocol.OpenUfsBlockOptions options)
Acquires access for a UFS block given a
UnderFileSystemBlockMeta and the limit on
the maximum concurrency on the block. |
void |
BlockMetadataManager.addTempBlockMeta(TempBlockMeta tempBlockMeta)
Adds a temp block.
|
void |
DefaultBlockWorker.closeUfsBlock(long sessionId,
long blockId) |
void |
BlockWorker.closeUfsBlock(long sessionId,
long blockId)
Closes a UFS block for a client session.
|
void |
DefaultBlockWorker.commitBlock(long sessionId,
long blockId,
boolean pinOnCreate) |
void |
TieredBlockStore.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.
|
void |
BlockMetadataManager.commitTempBlockMeta(TempBlockMeta tempBlockMeta)
Commits a temp block.
|
TempBlockMeta |
TieredBlockStore.createBlock(long sessionId,
long blockId,
BlockStoreLocation location,
long initialBlockSize) |
TempBlockMeta |
BlockStore.createBlock(long sessionId,
long blockId,
BlockStoreLocation location,
long initialBlockSize)
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 |
DefaultBlockWorker.createBlock(long sessionId,
long blockId,
String tierAlias,
String medium,
long initialBytes) |
String |
BlockWorker.createBlock(long sessionId,
long blockId,
String tierAlias,
String medium,
long initialBytes)
Creates a block in Alluxio managed space for short-circuit writes.
|
void |
DefaultBlockWorker.createBlockRemote(long sessionId,
long blockId,
String tierAlias,
String medium,
long initialBytes) |
void |
BlockWorker.createBlockRemote(long sessionId,
long blockId,
String tierAlias,
String medium,
long initialBytes)
Creates a block for non short-circuit writes or caching requests.
|
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.
|
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 for non short-circuit writes or
cache requests. |
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.
|
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.
|
boolean |
DefaultBlockWorker.openUfsBlock(long sessionId,
long blockId,
Protocol.OpenUfsBlockOptions options) |
boolean |
BlockWorker.openUfsBlock(long sessionId,
long blockId,
Protocol.OpenUfsBlockOptions options)
Opens a UFS block.
|
Modifier and Type | Method and Description |
---|---|
void |
StorageDir.addBlockMeta(BlockMeta blockMeta)
Adds the metadata of a new block into this storage dir.
|
void |
StorageDir.addTempBlockMeta(TempBlockMeta tempBlockMeta)
Adds the metadata of a new block into this storage dir.
|
static StorageDir |
StorageDir.newStorageDir(StorageTier tier,
int dirIndex,
long capacityBytes,
String dirPath,
String dirMedium)
Factory method to create
StorageDir . |
static StorageTier |
StorageTier.newStorageTier(String tierAlias)
Factory method to create
StorageTier . |
Copyright © 2023. All Rights Reserved.