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 |
MasterInfo._rename(int fileId,
TachyonURI dstPath,
long opTimeMs)
Rename a file to the given path, inner method.
|
boolean |
MasterServiceHandler.addCheckpoint(long workerId,
int fileId,
long fileSizeBytes,
String checkpointPath) |
int |
MasterInfo.cacheBlock(long workerId,
long workerUsedBytes,
long storageDirId,
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<TachyonURI> parents,
List<TachyonURI> 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(TachyonURI 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.
|
List<ClientBlockInfo> |
MasterInfo.getFileBlocks(int fileId)
Get the block infos of a file with the given id.
|
List<ClientBlockInfo> |
MasterInfo.getFileBlocks(TachyonURI path)
Get the block infos of a file with the given path.
|
List<ClientFileInfo> |
MasterInfo.getFilesInfo(TachyonURI path)
If the
path is a directory, return all the direct entries in it. |
int |
MasterInfo.getNumberOfFiles(TachyonURI path)
Get the number of files at a given path.
|
TachyonURI |
MasterInfo.getPath(int fileId)
Get the path of a file with the given id
|
List<Integer> |
MasterInfo.listFiles(TachyonURI path,
boolean recursive)
Get the id of the file at the given path.
|
List<ClientFileInfo> |
MasterServiceHandler.liststatus(String path) |
List<TachyonURI> |
MasterInfo.ls(TachyonURI path,
boolean recursive)
Get the names of the sub-directories at the given path.
|
boolean |
MasterInfo.rename(int fileId,
TachyonURI dstPath)
Rename a file to the given path.
|
boolean |
MasterInfo.rename(TachyonURI srcPath,
TachyonURI 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 |
MasterServiceHandler.user_getClientBlockInfo(long blockId) |
List<ClientBlockInfo> |
MasterServiceHandler.user_getFileBlocks(int fileId,
String path) |
boolean |
MasterServiceHandler.user_rename(int fileId,
String srcPath,
String dstPath) |
void |
MasterServiceHandler.user_reportLostFile(int fileId) |
void |
MasterServiceHandler.user_setPinned(int fileId,
boolean pinned) |
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 |
---|---|
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.user_setPinned_result.e |
FileDoesNotExistException |
MasterService.user_freepath_result.e |
FileDoesNotExistException |
MasterService.liststatus_result.eF |
FileDoesNotExistException |
MasterService.user_createDependency_result.eF |
FileDoesNotExistException |
MasterService.user_getClientBlockInfo_result.eF |
FileDoesNotExistException |
MasterService.user_getFileBlocks_result.eF |
FileDoesNotExistException |
MasterService.user_rename_result.eF |
FileDoesNotExistException |
WorkerService.addCheckpoint_result.eP |
FileDoesNotExistException |
WorkerService.cacheBlock_result.eP |
FileDoesNotExistException |
WorkerService.lockBlock_result.eP |
FileDoesNotExistException |
WorkerService.requestSpace_result.eP |
FileDoesNotExistException |
MasterService.addCheckpoint_result.eP |
FileDoesNotExistException |
MasterService.worker_cacheBlock_result.eP |
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.user_setPinned_result.getE() |
FileDoesNotExistException |
MasterService.user_freepath_result.getE() |
FileDoesNotExistException |
MasterService.liststatus_result.getEF() |
FileDoesNotExistException |
MasterService.user_createDependency_result.getEF() |
FileDoesNotExistException |
MasterService.user_getClientBlockInfo_result.getEF() |
FileDoesNotExistException |
MasterService.user_getFileBlocks_result.getEF() |
FileDoesNotExistException |
MasterService.user_rename_result.getEF() |
FileDoesNotExistException |
WorkerService.addCheckpoint_result.getEP() |
FileDoesNotExistException |
WorkerService.cacheBlock_result.getEP() |
FileDoesNotExistException |
WorkerService.lockBlock_result.getEP() |
FileDoesNotExistException |
WorkerService.requestSpace_result.getEP() |
FileDoesNotExistException |
MasterService.addCheckpoint_result.getEP() |
FileDoesNotExistException |
MasterService.worker_cacheBlock_result.getEP() |
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)
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() |
String |
WorkerService.AsyncClient.lockBlock_call.getResult() |
boolean |
WorkerService.AsyncClient.requestSpace_call.getResult() |
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() |
ClientBlockInfo |
MasterService.AsyncClient.user_getClientBlockInfo_call.getResult() |
List<ClientBlockInfo> |
MasterService.AsyncClient.user_getFileBlocks_call.getResult() |
boolean |
MasterService.AsyncClient.user_rename_call.getResult() |
void |
MasterService.AsyncClient.user_setPinned_call.getResult() |
boolean |
MasterService.AsyncClient.user_freepath_call.getResult() |
List<ClientFileInfo> |
MasterService.Iface.liststatus(String path) |
List<ClientFileInfo> |
MasterService.Client.liststatus(String path) |
String |
WorkerService.Iface.lockBlock(long blockId,
long userId)
Lock the file in Tachyon's space while the user is reading it, and the path of the block file
locked will be returned, if the block file is not found, FileDoesNotExistException will be
thrown.
|
String |
WorkerService.Client.lockBlock(long blockId,
long userId) |
void |
WorkerService.Client.recv_addCheckpoint() |
boolean |
MasterService.Client.recv_addCheckpoint() |
void |
WorkerService.Client.recv_cacheBlock() |
List<ClientFileInfo> |
MasterService.Client.recv_liststatus() |
String |
WorkerService.Client.recv_lockBlock() |
boolean |
WorkerService.Client.recv_requestSpace() |
void |
MasterService.Client.recv_user_completeFile() |
int |
MasterService.Client.recv_user_createDependency() |
long |
MasterService.Client.recv_user_createNewBlock() |
boolean |
MasterService.Client.recv_user_freepath() |
long |
MasterService.Client.recv_user_getBlockId() |
ClientBlockInfo |
MasterService.Client.recv_user_getClientBlockInfo() |
List<ClientBlockInfo> |
MasterService.Client.recv_user_getFileBlocks() |
boolean |
MasterService.Client.recv_user_rename() |
void |
MasterService.Client.recv_user_reportLostFile() |
void |
MasterService.Client.recv_user_setPinned() |
void |
MasterService.Client.recv_worker_cacheBlock() |
boolean |
WorkerService.Iface.requestSpace(long userId,
long blockId,
long requestBytes)
Used to request space for some block file.
|
boolean |
WorkerService.Client.requestSpace(long userId,
long blockId,
long requestBytes) |
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) |
boolean |
MasterService.Iface.user_freepath(int fileId,
String path,
boolean recursive) |
boolean |
MasterService.Client.user_freepath(int fileId,
String path,
boolean recursive) |
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) |
List<ClientBlockInfo> |
MasterService.Iface.user_getFileBlocks(int fileId,
String path)
Get file blocks info.
|
List<ClientBlockInfo> |
MasterService.Client.user_getFileBlocks(int fileId,
String path) |
boolean |
MasterService.Iface.user_rename(int fileId,
String srcPath,
String dstPath) |
boolean |
MasterService.Client.user_rename(int fileId,
String srcPath,
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 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) |
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) |
String |
WorkerServiceHandler.lockBlock(long blockId,
long userId) |
boolean |
WorkerStorage.requestSpace(long userId,
long blockId,
long requestBytes)
Request space from the specified StorageDir, it is used for requesting space for the block
which is partially written in some StorageDir
|
boolean |
WorkerServiceHandler.requestSpace(long userId,
long blockId,
long requestBytes) |
Copyright © 2015. All Rights Reserved.