Uses of Class
alluxio.exception.InvalidWorkerStateException

Packages that use InvalidWorkerStateException

Package	Description
alluxio.worker.block
alluxio.worker.block.meta

Uses of InvalidWorkerStateException in alluxio.worker.block

Methods in alluxio.worker.block that throw InvalidWorkerStateException

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	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	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	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.
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, 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.
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.
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.resizeTempBlockMeta(TempBlockMeta tempBlockMeta, long newSize) Modifies the size of a temp block.
void	BlockLockManager.validateLock(long sessionId, long blockId, long lockId) Validates the lock is hold by the given session for the given block.

Uses of InvalidWorkerStateException in alluxio.worker.block.meta

Methods in alluxio.worker.block.meta that throw InvalidWorkerStateException

Modifier and Type	Method and Description
void	StorageDir.resizeTempBlockMeta(TempBlockMeta tempBlockMeta, long newSize) Changes the size of a temp block.