Package | Description |
---|---|
tachyon.master | |
tachyon.thrift | |
tachyon.worker |
Modifier and Type | Method and Description |
---|---|
boolean |
MasterClient.addCheckpoint(long workerId,
int fileId,
long length,
String checkpointPath) |
boolean |
MasterInfo.addCheckpoint(long workerId,
int fileId,
long length,
String checkpointPath)
Add a checkpoint to a file.
|
boolean |
MasterServiceHandler.addCheckpoint(long workerId,
int fileId,
long fileSizeBytes,
String checkpointPath) |
int |
MasterInfo.cacheBlock(long workerId,
long workerUsedBytes,
long blockId,
long length)
A worker cache a block in its memory.
|
void |
InodeFile.setLength(long length) |
int |
MasterServiceHandler.user_createFileOnCheckpoint(String path,
String checkpointPath) |
void |
MasterClient.worker_cacheBlock(long workerId,
long workerUsedBytes,
long blockId,
long length) |
void |
MasterServiceHandler.worker_cacheBlock(long workerId,
long workerUsedBytes,
long blockId,
long length) |
Modifier and Type | Field and Description |
---|---|
SuspectedFileSizeException |
MasterService.addCheckpoint_result.eS |
SuspectedFileSizeException |
MasterService.worker_cacheBlock_result.eS |
SuspectedFileSizeException |
MasterService.user_createFileOnCheckpoint_result.eS |
SuspectedFileSizeException |
WorkerService.addCheckpoint_result.eS |
SuspectedFileSizeException |
WorkerService.cacheBlock_result.eS |
Modifier and Type | Method and Description |
---|---|
SuspectedFileSizeException |
SuspectedFileSizeException.deepCopy() |
SuspectedFileSizeException |
MasterService.addCheckpoint_result.getES() |
SuspectedFileSizeException |
MasterService.worker_cacheBlock_result.getES() |
SuspectedFileSizeException |
MasterService.user_createFileOnCheckpoint_result.getES() |
SuspectedFileSizeException |
WorkerService.addCheckpoint_result.getES() |
SuspectedFileSizeException |
WorkerService.cacheBlock_result.getES() |
SuspectedFileSizeException |
SuspectedFileSizeException.setMessage(String message) |
Modifier and Type | Method and Description |
---|---|
int |
SuspectedFileSizeException.compareTo(SuspectedFileSizeException other) |
boolean |
SuspectedFileSizeException.equals(SuspectedFileSizeException that) |
MasterService.addCheckpoint_result |
MasterService.addCheckpoint_result.setES(SuspectedFileSizeException eS) |
MasterService.worker_cacheBlock_result |
MasterService.worker_cacheBlock_result.setES(SuspectedFileSizeException eS) |
MasterService.user_createFileOnCheckpoint_result |
MasterService.user_createFileOnCheckpoint_result.setES(SuspectedFileSizeException eS) |
WorkerService.addCheckpoint_result |
WorkerService.addCheckpoint_result.setES(SuspectedFileSizeException eS) |
WorkerService.cacheBlock_result |
WorkerService.cacheBlock_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) |
void |
WorkerService.Client.cacheBlock(long userId,
long blockId) |
boolean |
MasterService.AsyncClient.addCheckpoint_call.getResult() |
void |
MasterService.AsyncClient.worker_cacheBlock_call.getResult() |
int |
MasterService.AsyncClient.user_createFileOnCheckpoint_call.getResult() |
void |
WorkerService.AsyncClient.addCheckpoint_call.getResult() |
void |
WorkerService.AsyncClient.cacheBlock_call.getResult() |
boolean |
MasterService.Client.recv_addCheckpoint() |
void |
WorkerService.Client.recv_addCheckpoint() |
void |
WorkerService.Client.recv_cacheBlock() |
int |
MasterService.Client.recv_user_createFileOnCheckpoint() |
void |
MasterService.Client.recv_worker_cacheBlock() |
int |
MasterService.Iface.user_createFileOnCheckpoint(String path,
String checkpointPath) |
int |
MasterService.Client.user_createFileOnCheckpoint(String path,
String checkpointPath) |
void |
MasterService.Iface.worker_cacheBlock(long workerId,
long workerUsedBytes,
long blockId,
long length) |
void |
MasterService.Client.worker_cacheBlock(long workerId,
long workerUsedBytes,
long blockId,
long length) |
Constructor and Description |
---|
addCheckpoint_result(boolean success,
FileDoesNotExistException eP,
SuspectedFileSizeException eS,
BlockInfoException eB) |
addCheckpoint_result(FileDoesNotExistException eP,
SuspectedFileSizeException eS,
FailedToCheckpointException eF,
BlockInfoException eB) |
cacheBlock_result(FileDoesNotExistException eP,
SuspectedFileSizeException eS,
BlockInfoException eB) |
SuspectedFileSizeException(SuspectedFileSizeException other)
Performs a deep copy on other.
|
user_createFileOnCheckpoint_result(int success,
FileAlreadyExistException eR,
InvalidPathException eI,
SuspectedFileSizeException eS,
BlockInfoException eB,
TachyonException eT) |
worker_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 © 2014. All rights reserved.