Package | Description |
---|---|
tachyon.worker |
Worker process and utils for working with the worker remotely.
|
tachyon.worker.allocation | |
tachyon.worker.eviction | |
tachyon.worker.hierarchy |
Modifier and Type | Method and Description |
---|---|
StorageDir |
WorkerStorage.getStorageDirByBlockId(long blockId)
Get StorageDir which contains specified block
|
StorageDir |
BlocksLocker.lock(long blockId,
int blockLockId)
Lock a block with specified lock id.
|
StorageDir |
WorkerStorage.lockBlock(long blockId,
long userId)
Lock the block by some user
Used internally to make sure blocks are unmodified, but also used in
TachyonFS for caching blocks locally for users. |
StorageDir |
BlocksLocker.locked(long blockId)
Get StorageDir in which the block is locked
|
Modifier and Type | Method and Description |
---|---|
StorageDir |
AllocateRandom.getStorageDir(StorageDir[] storageDirs,
long userId,
long requestBytes) |
StorageDir |
AllocateMaxFree.getStorageDir(StorageDir[] storageDirs,
long userId,
long requestSizeBytes) |
StorageDir |
AllocateStrategy.getStorageDir(StorageDir[] storageDirs,
long userId,
long requestSizeBytes)
Allocate space on StorageDirs.
|
StorageDir |
AllocateRR.getStorageDir(StorageDir[] storageDirs,
long userId,
long requestSizeBytes) |
Modifier and Type | Method and Description |
---|---|
boolean |
AllocateStrategy.fitInPossible(StorageDir[] storageDirs,
long requestSizeBytes)
Check whether it is possible to get enough space by evicting some blocks
|
boolean |
AllocateStrategyBase.fitInPossible(StorageDir[] storageDirs,
long requestSizeBytes) |
StorageDir |
AllocateRandom.getStorageDir(StorageDir[] storageDirs,
long userId,
long requestBytes) |
StorageDir |
AllocateMaxFree.getStorageDir(StorageDir[] storageDirs,
long userId,
long requestSizeBytes) |
StorageDir |
AllocateStrategy.getStorageDir(StorageDir[] storageDirs,
long userId,
long requestSizeBytes)
Allocate space on StorageDirs.
|
StorageDir |
AllocateRR.getStorageDir(StorageDir[] storageDirs,
long userId,
long requestSizeBytes) |
Modifier and Type | Method and Description |
---|---|
Pair<StorageDir,List<BlockInfo>> |
EvictPartialLRU.getDirCandidate(StorageDir[] storageDirs,
Set<Integer> pinList,
long requestBytes) |
Pair<StorageDir,List<BlockInfo>> |
EvictLRU.getDirCandidate(StorageDir[] storageDirs,
Set<Integer> pinList,
long requestBytes) |
Pair<StorageDir,List<BlockInfo>> |
EvictStrategy.getDirCandidate(StorageDir[] storageDirs,
Set<Integer> pinList,
long requestBytes)
Get StorageDir allocated and also get blocks to be evicted among StorageDir candidates
|
Modifier and Type | Method and Description |
---|---|
Pair<StorageDir,List<BlockInfo>> |
EvictPartialLRU.getDirCandidate(StorageDir[] storageDirs,
Set<Integer> pinList,
long requestBytes) |
Pair<StorageDir,List<BlockInfo>> |
EvictLRU.getDirCandidate(StorageDir[] storageDirs,
Set<Integer> pinList,
long requestBytes) |
Pair<StorageDir,List<BlockInfo>> |
EvictStrategy.getDirCandidate(StorageDir[] storageDirs,
Set<Integer> pinList,
long requestBytes)
Get StorageDir allocated and also get blocks to be evicted among StorageDir candidates
|
protected Pair<Long,Long> |
EvictLRUBase.getLRUBlock(StorageDir curDir,
Collection<Long> toEvictBlockIds,
Set<Integer> pinList)
Get the oldest access information of certain StorageDir
|
Modifier and Type | Method and Description |
---|---|
StorageDir |
BlockInfo.getStorageDir()
Get the StorageDir which contains the block
|
StorageDir |
StorageTier.getStorageDirByBlockId(long blockId)
Find the StorageDir which contains the given block Id
|
StorageDir |
StorageTier.getStorageDirByIndex(int dirIndex)
Get StorageDir by array index
|
StorageDir[] |
StorageTier.getStorageDirs()
Get StorageDirs in current StorageTier
|
StorageDir |
StorageTier.requestSpace(long userId,
long requestBytes,
Set<Integer> pinList,
List<Long> removedBlockIds)
Request space from any StorageDir in the StorageTier.
|
Modifier and Type | Method and Description |
---|---|
boolean |
StorageDir.copyBlock(long blockId,
StorageDir dstDir)
Copy block file from this StorageDir to another StorageDir, the caller needs to make sure the
block is locked during copying
|
boolean |
StorageDir.moveBlock(long blockId,
StorageDir dstDir)
Move a block from its current StorageDir to another StorageDir
|
boolean |
StorageTier.requestSpace(StorageDir storageDir,
long userId,
long requestBytes,
Set<Integer> pinList,
List<Long> removedBlockIds)
Request space from specified StorageDir in the StorageTier.
|
Constructor and Description |
---|
BlockInfo(StorageDir storageDir,
long blockId,
long blockSize) |
Copyright © 2015. All Rights Reserved.