Package | Description |
---|---|
tachyon.master | |
tachyon.thrift | |
tachyon.worker |
Worker process and utils for working with the worker remotely.
|
Modifier and Type | Method and Description |
---|---|
boolean |
MasterServiceHandler.addCheckpoint(long workerId,
int fileId,
long fileSizeBytes,
String checkpointPath) |
boolean |
MasterInfo.addCheckpoint(long workerId,
int fileId,
long length,
TachyonURI checkpointPath)
Add a checkpoint to a file.
|
int |
MasterInfo.cacheBlock(long workerId,
long workerUsedBytes,
long storageDirId,
long blockId,
long length)
A worker cache a block in its memory.
|
void |
InodeFile.setLength(long length)
Set the length of the file.
|
int |
MasterServiceHandler.user_createFile(String path,
String ufsPath,
long blockSizeByte,
boolean recursive) |
void |
MasterServiceHandler.worker_cacheBlock(long workerId,
long workerUsedBytes,
long storageDirId,
long blockId,
long length) |
void |
MasterClient.worker_cacheBlock(long workerId,
long workerUsedBytes,
long storageDirId,
long blockId,
long length) |
Modifier and Type | Field and Description |
---|---|
SuspectedFileSizeException |
WorkerService.addCheckpoint_result.eS |
SuspectedFileSizeException |
WorkerService.cacheBlock_result.eS |
SuspectedFileSizeException |
MasterService.addCheckpoint_result.eS |
SuspectedFileSizeException |
MasterService.worker_cacheBlock_result.eS |
SuspectedFileSizeException |
MasterService.user_createFile_result.eS |
Modifier and Type | Method and Description |
---|---|
SuspectedFileSizeException |
SuspectedFileSizeException.deepCopy() |
SuspectedFileSizeException |
WorkerService.addCheckpoint_result.getES() |
SuspectedFileSizeException |
WorkerService.cacheBlock_result.getES() |
SuspectedFileSizeException |
MasterService.addCheckpoint_result.getES() |
SuspectedFileSizeException |
MasterService.worker_cacheBlock_result.getES() |
SuspectedFileSizeException |
MasterService.user_createFile_result.getES() |
SuspectedFileSizeException |
SuspectedFileSizeException.setMessage(String message) |
Modifier and Type | Method and Description |
---|---|
int |
SuspectedFileSizeException.compareTo(SuspectedFileSizeException other) |
boolean |
SuspectedFileSizeException.equals(SuspectedFileSizeException that) |
WorkerService.addCheckpoint_result |
WorkerService.addCheckpoint_result.setES(SuspectedFileSizeException eS) |
WorkerService.cacheBlock_result |
WorkerService.cacheBlock_result.setES(SuspectedFileSizeException eS) |
MasterService.addCheckpoint_result |
MasterService.addCheckpoint_result.setES(SuspectedFileSizeException eS) |
MasterService.worker_cacheBlock_result |
MasterService.worker_cacheBlock_result.setES(SuspectedFileSizeException eS) |
MasterService.user_createFile_result |
MasterService.user_createFile_result.setES(SuspectedFileSizeException eS) |
Modifier and Type | Method and Description |
---|---|
void |
WorkerService.Iface.addCheckpoint(long userId,
int fileId) |
void |
WorkerService.Client.addCheckpoint(long userId,
int fileId) |
boolean |
MasterService.Iface.addCheckpoint(long workerId,
int fileId,
long length,
String checkpointPath) |
boolean |
MasterService.Client.addCheckpoint(long workerId,
int fileId,
long length,
String checkpointPath) |
void |
WorkerService.Iface.cacheBlock(long userId,
long blockId)
Used to cache a block into Tachyon space, worker will move the temporary block file from user
folder to data folder, and update the space usage information related.
|
void |
WorkerService.Client.cacheBlock(long userId,
long blockId) |
void |
WorkerService.AsyncClient.addCheckpoint_call.getResult() |
void |
WorkerService.AsyncClient.cacheBlock_call.getResult() |
boolean |
MasterService.AsyncClient.addCheckpoint_call.getResult() |
void |
MasterService.AsyncClient.worker_cacheBlock_call.getResult() |
int |
MasterService.AsyncClient.user_createFile_call.getResult() |
void |
WorkerService.Client.recv_addCheckpoint() |
boolean |
MasterService.Client.recv_addCheckpoint() |
void |
WorkerService.Client.recv_cacheBlock() |
int |
MasterService.Client.recv_user_createFile() |
void |
MasterService.Client.recv_worker_cacheBlock() |
int |
MasterService.Iface.user_createFile(String path,
String ufsPath,
long blockSizeByte,
boolean recursive) |
int |
MasterService.Client.user_createFile(String path,
String ufsPath,
long blockSizeByte,
boolean recursive) |
void |
MasterService.Iface.worker_cacheBlock(long workerId,
long workerUsedBytes,
long storageDirId,
long blockId,
long length)
Update information of the block newly cached to master, including used Tachyon space size in
bytes, the id of the storage directory in which the block is, the id of the block and the size
of the block in bytes.
|
void |
MasterService.Client.worker_cacheBlock(long workerId,
long workerUsedBytes,
long storageDirId,
long blockId,
long length) |
Constructor and Description |
---|
MasterService.addCheckpoint_result(boolean success,
FileDoesNotExistException eP,
SuspectedFileSizeException eS,
BlockInfoException eB) |
MasterService.user_createFile_result(int success,
FileAlreadyExistException eR,
InvalidPathException eI,
BlockInfoException eB,
SuspectedFileSizeException eS,
TachyonException eT) |
MasterService.worker_cacheBlock_result(FileDoesNotExistException eP,
SuspectedFileSizeException eS,
BlockInfoException eB) |
SuspectedFileSizeException(SuspectedFileSizeException other)
Performs a deep copy on other.
|
WorkerService.addCheckpoint_result(FileDoesNotExistException eP,
SuspectedFileSizeException eS,
FailedToCheckpointException eF,
BlockInfoException eB) |
WorkerService.cacheBlock_result(FileDoesNotExistException eP,
SuspectedFileSizeException eS,
BlockInfoException eB) |
Modifier and Type | Method and Description |
---|---|
void |
WorkerStorage.addCheckpoint(long userId,
int fileId)
Add the checkpoint information of a file.
|
void |
WorkerServiceHandler.addCheckpoint(long userId,
int fileId) |
void |
WorkerStorage.cacheBlock(long userId,
long blockId)
Notify the worker the block is cached.
|
void |
WorkerServiceHandler.cacheBlock(long userId,
long blockId) |
Copyright © 2015. All Rights Reserved.