Package | Description |
---|---|
tachyon.master | |
tachyon.thrift | |
tachyon.worker |
Modifier and Type | Method and Description |
---|---|
boolean |
MasterInfo._rename(int fileId,
String dstPath)
Rename a file to the given path, inner method.
|
boolean |
MasterClient.addCheckpoint(long workerId,
int fileId,
long length,
String checkpointPath) |
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 |
MasterInfo.completeFile(int fileId)
Completes the checkpointing of a file.
|
int |
MasterInfo.createDependency(List<String> parents,
List<String> children,
String commandPrefix,
List<ByteBuffer> data,
String comment,
String framework,
String frameworkVersion,
DependencyType dependencyType) |
long |
MasterInfo.createNewBlock(int fileId)
Creates a new block for the given file.
|
long |
MasterInfo.getBlockIdBasedOnOffset(int fileId,
long offset) |
List<BlockInfo> |
MasterInfo.getBlockList(String path)
Get the list of blocks of an InodeFile determined by path.
|
ClientBlockInfo |
MasterInfo.getClientBlockInfo(long blockId)
Get the block info associated with the given id.
|
ClientFileInfo |
MasterInfo.getClientFileInfo(int fid)
Get the file info associated with the given id.
|
ClientFileInfo |
MasterInfo.getClientFileInfo(String path)
Get the file info for the file at the given path
|
ClientFileInfo |
MasterServiceHandler.getClientFileInfoById(int id) |
List<ClientBlockInfo> |
MasterInfo.getFileLocations(int fileId)
Get the block infos of a file with the given id.
|
List<ClientBlockInfo> |
MasterInfo.getFileLocations(String path)
Get the block infos of a file with the given path.
|
List<ClientFileInfo> |
MasterInfo.getFilesInfo(String path)
If the
path is a directory, return all the direct entries in
it. |
int |
MasterInfo.getNumberOfFiles(String path)
Get the number of files at a given path.
|
String |
MasterInfo.getPath(int fileId)
Get the path of a file with the given id
|
List<Integer> |
MasterInfo.listFiles(String path,
boolean recursive)
Get the id of the file at the given path.
|
List<ClientFileInfo> |
MasterServiceHandler.liststatus(String path) |
List<String> |
MasterInfo.ls(String path,
boolean recursive)
Get the names of the sub-directories at the given path.
|
boolean |
MasterInfo.rename(int fileId,
String dstPath)
Rename a file to the given path.
|
boolean |
MasterInfo.rename(String srcPath,
String dstPath)
Rename a file to the given path.
|
void |
MasterInfo.setPinned(int fileId,
boolean pinned)
Sets the isPinned flag on the given inode and all of its children.
|
void |
MasterServiceHandler.user_completeFile(int fileId) |
int |
MasterServiceHandler.user_createDependency(List<String> parents,
List<String> children,
String commandPrefix,
List<ByteBuffer> data,
String comment,
String framework,
String frameworkVersion,
int dependencyType,
long childrenBlockSizeByte) |
long |
MasterServiceHandler.user_createNewBlock(int fileId) |
long |
MasterServiceHandler.user_getBlockId(int fileId,
int index) |
ClientBlockInfo |
MasterClient.user_getClientBlockInfo(long blockId) |
ClientBlockInfo |
MasterServiceHandler.user_getClientBlockInfo(long blockId) |
ClientFileInfo |
MasterServiceHandler.user_getClientFileInfoByPath(String path) |
List<ClientBlockInfo> |
MasterServiceHandler.user_getFileBlocksById(int fileId) |
List<ClientBlockInfo> |
MasterServiceHandler.user_getFileBlocksByPath(String path) |
int |
MasterServiceHandler.user_getNumberOfFiles(String path) |
List<Integer> |
MasterServiceHandler.user_listFiles(String path,
boolean recursive) |
List<String> |
MasterServiceHandler.user_ls(String path,
boolean recursive) |
boolean |
MasterServiceHandler.user_rename(String srcPath,
String dstPath) |
void |
MasterServiceHandler.user_renameTo(int fileId,
String dstPath) |
void |
MasterServiceHandler.user_reportLostFile(int fileId) |
void |
MasterServiceHandler.user_setPinned(int fileId,
boolean pinned) |
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 |
---|---|
FileDoesNotExistException |
MasterService.user_reportLostFile_result.e |
FileDoesNotExistException |
MasterService.user_createNewBlock_result.e |
FileDoesNotExistException |
MasterService.user_completeFile_result.e |
FileDoesNotExistException |
MasterService.user_getBlockId_result.e |
FileDoesNotExistException |
MasterService.getClientFileInfoById_result.e |
FileDoesNotExistException |
MasterService.user_getFileBlocksById_result.e |
FileDoesNotExistException |
MasterService.user_setPinned_result.e |
FileDoesNotExistException |
MasterService.liststatus_result.eF |
FileDoesNotExistException |
MasterService.user_createDependency_result.eF |
FileDoesNotExistException |
MasterService.user_getClientFileInfoByPath_result.eF |
FileDoesNotExistException |
MasterService.user_getClientBlockInfo_result.eF |
FileDoesNotExistException |
MasterService.user_getFileBlocksByPath_result.eF |
FileDoesNotExistException |
MasterService.user_listFiles_result.eF |
FileDoesNotExistException |
MasterService.user_ls_result.eF |
FileDoesNotExistException |
MasterService.user_rename_result.eF |
FileDoesNotExistException |
MasterService.user_renameTo_result.eF |
FileDoesNotExistException |
MasterService.addCheckpoint_result.eP |
FileDoesNotExistException |
MasterService.worker_cacheBlock_result.eP |
FileDoesNotExistException |
WorkerService.addCheckpoint_result.eP |
FileDoesNotExistException |
WorkerService.cacheBlock_result.eP |
FileDoesNotExistException |
MasterService.user_getNumberOfFiles_result.eR |
Modifier and Type | Method and Description |
---|---|
FileDoesNotExistException |
FileDoesNotExistException.deepCopy() |
FileDoesNotExistException |
MasterService.user_reportLostFile_result.getE() |
FileDoesNotExistException |
MasterService.user_createNewBlock_result.getE() |
FileDoesNotExistException |
MasterService.user_completeFile_result.getE() |
FileDoesNotExistException |
MasterService.user_getBlockId_result.getE() |
FileDoesNotExistException |
MasterService.getClientFileInfoById_result.getE() |
FileDoesNotExistException |
MasterService.user_getFileBlocksById_result.getE() |
FileDoesNotExistException |
MasterService.user_setPinned_result.getE() |
FileDoesNotExistException |
MasterService.liststatus_result.getEF() |
FileDoesNotExistException |
MasterService.user_createDependency_result.getEF() |
FileDoesNotExistException |
MasterService.user_getClientFileInfoByPath_result.getEF() |
FileDoesNotExistException |
MasterService.user_getClientBlockInfo_result.getEF() |
FileDoesNotExistException |
MasterService.user_getFileBlocksByPath_result.getEF() |
FileDoesNotExistException |
MasterService.user_listFiles_result.getEF() |
FileDoesNotExistException |
MasterService.user_ls_result.getEF() |
FileDoesNotExistException |
MasterService.user_rename_result.getEF() |
FileDoesNotExistException |
MasterService.user_renameTo_result.getEF() |
FileDoesNotExistException |
MasterService.addCheckpoint_result.getEP() |
FileDoesNotExistException |
MasterService.worker_cacheBlock_result.getEP() |
FileDoesNotExistException |
WorkerService.addCheckpoint_result.getEP() |
FileDoesNotExistException |
WorkerService.cacheBlock_result.getEP() |
FileDoesNotExistException |
MasterService.user_getNumberOfFiles_result.getER() |
FileDoesNotExistException |
FileDoesNotExistException.setMessage(String message) |
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) |
ClientFileInfo |
MasterService.Iface.getClientFileInfoById(int fileId) |
ClientFileInfo |
MasterService.Client.getClientFileInfoById(int fileId) |
boolean |
MasterService.AsyncClient.addCheckpoint_call.getResult() |
List<ClientFileInfo> |
MasterService.AsyncClient.liststatus_call.getResult() |
void |
MasterService.AsyncClient.worker_cacheBlock_call.getResult() |
int |
MasterService.AsyncClient.user_createDependency_call.getResult() |
void |
MasterService.AsyncClient.user_reportLostFile_call.getResult() |
long |
MasterService.AsyncClient.user_createNewBlock_call.getResult() |
void |
MasterService.AsyncClient.user_completeFile_call.getResult() |
long |
MasterService.AsyncClient.user_getBlockId_call.getResult() |
ClientFileInfo |
MasterService.AsyncClient.getClientFileInfoById_call.getResult() |
ClientFileInfo |
MasterService.AsyncClient.user_getClientFileInfoByPath_call.getResult() |
ClientBlockInfo |
MasterService.AsyncClient.user_getClientBlockInfo_call.getResult() |
List<ClientBlockInfo> |
MasterService.AsyncClient.user_getFileBlocksById_call.getResult() |
List<ClientBlockInfo> |
MasterService.AsyncClient.user_getFileBlocksByPath_call.getResult() |
List<Integer> |
MasterService.AsyncClient.user_listFiles_call.getResult() |
List<String> |
MasterService.AsyncClient.user_ls_call.getResult() |
boolean |
MasterService.AsyncClient.user_rename_call.getResult() |
void |
MasterService.AsyncClient.user_renameTo_call.getResult() |
void |
MasterService.AsyncClient.user_setPinned_call.getResult() |
int |
MasterService.AsyncClient.user_getNumberOfFiles_call.getResult() |
void |
WorkerService.AsyncClient.addCheckpoint_call.getResult() |
void |
WorkerService.AsyncClient.cacheBlock_call.getResult() |
List<ClientFileInfo> |
MasterService.Iface.liststatus(String path) |
List<ClientFileInfo> |
MasterService.Client.liststatus(String path) |
boolean |
MasterService.Client.recv_addCheckpoint() |
void |
WorkerService.Client.recv_addCheckpoint() |
void |
WorkerService.Client.recv_cacheBlock() |
ClientFileInfo |
MasterService.Client.recv_getClientFileInfoById() |
List<ClientFileInfo> |
MasterService.Client.recv_liststatus() |
void |
MasterService.Client.recv_user_completeFile() |
int |
MasterService.Client.recv_user_createDependency() |
long |
MasterService.Client.recv_user_createNewBlock() |
long |
MasterService.Client.recv_user_getBlockId() |
ClientBlockInfo |
MasterService.Client.recv_user_getClientBlockInfo() |
ClientFileInfo |
MasterService.Client.recv_user_getClientFileInfoByPath() |
List<ClientBlockInfo> |
MasterService.Client.recv_user_getFileBlocksById() |
List<ClientBlockInfo> |
MasterService.Client.recv_user_getFileBlocksByPath() |
int |
MasterService.Client.recv_user_getNumberOfFiles() |
List<Integer> |
MasterService.Client.recv_user_listFiles() |
List<String> |
MasterService.Client.recv_user_ls() |
boolean |
MasterService.Client.recv_user_rename() |
void |
MasterService.Client.recv_user_renameTo() |
void |
MasterService.Client.recv_user_reportLostFile() |
void |
MasterService.Client.recv_user_setPinned() |
void |
MasterService.Client.recv_worker_cacheBlock() |
void |
MasterService.Iface.user_completeFile(int fileId) |
void |
MasterService.Client.user_completeFile(int fileId) |
int |
MasterService.Iface.user_createDependency(List<String> parents,
List<String> children,
String commandPrefix,
List<ByteBuffer> data,
String comment,
String framework,
String frameworkVersion,
int dependencyType,
long childrenBlockSizeByte) |
int |
MasterService.Client.user_createDependency(List<String> parents,
List<String> children,
String commandPrefix,
List<ByteBuffer> data,
String comment,
String framework,
String frameworkVersion,
int dependencyType,
long childrenBlockSizeByte) |
long |
MasterService.Iface.user_createNewBlock(int fileId) |
long |
MasterService.Client.user_createNewBlock(int fileId) |
long |
MasterService.Iface.user_getBlockId(int fileId,
int index) |
long |
MasterService.Client.user_getBlockId(int fileId,
int index) |
ClientBlockInfo |
MasterService.Iface.user_getClientBlockInfo(long blockId)
Get block's ClientBlockInfo.
|
ClientBlockInfo |
MasterService.Client.user_getClientBlockInfo(long blockId) |
ClientFileInfo |
MasterService.Iface.user_getClientFileInfoByPath(String path) |
ClientFileInfo |
MasterService.Client.user_getClientFileInfoByPath(String path) |
List<ClientBlockInfo> |
MasterService.Iface.user_getFileBlocksById(int fileId)
Get file locations by file Id.
|
List<ClientBlockInfo> |
MasterService.Client.user_getFileBlocksById(int fileId) |
List<ClientBlockInfo> |
MasterService.Iface.user_getFileBlocksByPath(String path)
Get file locations by path
|
List<ClientBlockInfo> |
MasterService.Client.user_getFileBlocksByPath(String path) |
int |
MasterService.Iface.user_getNumberOfFiles(String path) |
int |
MasterService.Client.user_getNumberOfFiles(String path) |
List<Integer> |
MasterService.Iface.user_listFiles(String path,
boolean recursive) |
List<Integer> |
MasterService.Client.user_listFiles(String path,
boolean recursive) |
List<String> |
MasterService.Iface.user_ls(String path,
boolean recursive) |
List<String> |
MasterService.Client.user_ls(String path,
boolean recursive) |
boolean |
MasterService.Iface.user_rename(String srcPath,
String dstPath) |
boolean |
MasterService.Client.user_rename(String srcPath,
String dstPath) |
void |
MasterService.Iface.user_renameTo(int fileId,
String dstPath) |
void |
MasterService.Client.user_renameTo(int fileId,
String dstPath) |
void |
MasterService.Iface.user_reportLostFile(int fileId) |
void |
MasterService.Client.user_reportLostFile(int fileId) |
void |
MasterService.Iface.user_setPinned(int fileId,
boolean pinned) |
void |
MasterService.Client.user_setPinned(int fileId,
boolean pinned) |
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) |
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.