public static interface MasterService.Iface
| Modifier and Type | Method and Description |
|---|---|
boolean |
addCheckpoint(long workerId,
int fileId,
long length,
String checkpointPath) |
ClientFileInfo |
getClientFileInfoById(int fileId) |
List<ClientWorkerInfo> |
getWorkersInfo() |
List<ClientFileInfo> |
liststatus(String path) |
void |
user_completeFile(int fileId) |
int |
user_createDependency(List<String> parents,
List<String> children,
String commandPrefix,
List<ByteBuffer> data,
String comment,
String framework,
String frameworkVersion,
int dependencyType,
long childrenBlockSizeByte) |
int |
user_createFile(String path,
long blockSizeByte) |
int |
user_createFileOnCheckpoint(String path,
String checkpointPath) |
long |
user_createNewBlock(int fileId) |
int |
user_createRawTable(String path,
int columns,
ByteBuffer metadata) |
boolean |
user_deleteById(int fileId,
boolean recursive) |
boolean |
user_deleteByPath(String path,
boolean recursive) |
long |
user_getBlockId(int fileId,
int index) |
ClientBlockInfo |
user_getClientBlockInfo(long blockId)
Get block's ClientBlockInfo.
|
ClientDependencyInfo |
user_getClientDependencyInfo(int dependencyId) |
ClientFileInfo |
user_getClientFileInfoByPath(String path) |
ClientRawTableInfo |
user_getClientRawTableInfoById(int tableId) |
ClientRawTableInfo |
user_getClientRawTableInfoByPath(String tablePath) |
List<ClientBlockInfo> |
user_getFileBlocksById(int fileId)
Get file locations by file Id.
|
List<ClientBlockInfo> |
user_getFileBlocksByPath(String path)
Get file locations by path
|
int |
user_getFileId(String path)
Return -1 if does not contain the file, return fileId if it exists.
|
int |
user_getNumberOfFiles(String path) |
int |
user_getRawTableId(String path) |
String |
user_getUnderfsAddress() |
long |
user_getUserId() |
NetAddress |
user_getWorker(boolean random,
String host)
Get local worker NetAddress
|
List<Integer> |
user_listFiles(String path,
boolean recursive) |
List<String> |
user_ls(String path,
boolean recursive) |
boolean |
user_mkdir(String path) |
void |
user_outOfMemoryForPinFile(int fileId) |
void |
user_rename(String srcPath,
String dstPath) |
void |
user_renameTo(int fileId,
String dstPath) |
void |
user_reportLostFile(int fileId) |
void |
user_requestFilesInDependency(int depId) |
void |
user_unpinFile(int fileId) |
void |
user_updateRawTableMetadata(int tableId,
ByteBuffer metadata) |
void |
worker_cacheBlock(long workerId,
long workerUsedBytes,
long blockId,
long length) |
Set<Integer> |
worker_getPinIdList() |
List<Integer> |
worker_getPriorityDependencyList() |
Command |
worker_heartbeat(long workerId,
long usedBytes,
List<Long> removedBlocks) |
long |
worker_register(NetAddress workerNetAddress,
long totalBytes,
long usedBytes,
List<Long> currentBlocks)
Worker register.
|
boolean addCheckpoint(long workerId,
int fileId,
long length,
String checkpointPath)
throws FileDoesNotExistException,
SuspectedFileSizeException,
BlockInfoException,
org.apache.thrift.TException
FileDoesNotExistExceptionSuspectedFileSizeExceptionBlockInfoExceptionorg.apache.thrift.TExceptionList<ClientWorkerInfo> getWorkersInfo() throws org.apache.thrift.TException
org.apache.thrift.TExceptionList<ClientFileInfo> liststatus(String path) throws InvalidPathException, FileDoesNotExistException, org.apache.thrift.TException
InvalidPathExceptionFileDoesNotExistExceptionorg.apache.thrift.TExceptionlong worker_register(NetAddress workerNetAddress, long totalBytes, long usedBytes, List<Long> currentBlocks) throws BlockInfoException, org.apache.thrift.TException
workerNetAddress - totalBytes - usedBytes - currentBlocks - BlockInfoExceptionorg.apache.thrift.TExceptionCommand worker_heartbeat(long workerId, long usedBytes, List<Long> removedBlocks) throws BlockInfoException, org.apache.thrift.TException
BlockInfoExceptionorg.apache.thrift.TExceptionvoid worker_cacheBlock(long workerId,
long workerUsedBytes,
long blockId,
long length)
throws FileDoesNotExistException,
SuspectedFileSizeException,
BlockInfoException,
org.apache.thrift.TException
FileDoesNotExistExceptionSuspectedFileSizeExceptionBlockInfoExceptionorg.apache.thrift.TExceptionSet<Integer> worker_getPinIdList() throws org.apache.thrift.TException
org.apache.thrift.TExceptionList<Integer> worker_getPriorityDependencyList() throws org.apache.thrift.TException
org.apache.thrift.TExceptionint user_createDependency(List<String> parents, List<String> children, String commandPrefix, List<ByteBuffer> data, String comment, String framework, String frameworkVersion, int dependencyType, long childrenBlockSizeByte) throws InvalidPathException, FileDoesNotExistException, FileAlreadyExistException, BlockInfoException, TachyonException, org.apache.thrift.TException
InvalidPathExceptionFileDoesNotExistExceptionFileAlreadyExistExceptionBlockInfoExceptionTachyonExceptionorg.apache.thrift.TExceptionClientDependencyInfo user_getClientDependencyInfo(int dependencyId) throws DependencyDoesNotExistException, org.apache.thrift.TException
DependencyDoesNotExistExceptionorg.apache.thrift.TExceptionvoid user_reportLostFile(int fileId)
throws FileDoesNotExistException,
org.apache.thrift.TException
FileDoesNotExistExceptionorg.apache.thrift.TExceptionvoid user_requestFilesInDependency(int depId)
throws DependencyDoesNotExistException,
org.apache.thrift.TException
DependencyDoesNotExistExceptionorg.apache.thrift.TExceptionint user_createFile(String path, long blockSizeByte) throws FileAlreadyExistException, InvalidPathException, BlockInfoException, TachyonException, org.apache.thrift.TException
FileAlreadyExistExceptionInvalidPathExceptionBlockInfoExceptionTachyonExceptionorg.apache.thrift.TExceptionint user_createFileOnCheckpoint(String path, String checkpointPath) throws FileAlreadyExistException, InvalidPathException, SuspectedFileSizeException, BlockInfoException, TachyonException, org.apache.thrift.TException
FileAlreadyExistExceptionInvalidPathExceptionSuspectedFileSizeExceptionBlockInfoExceptionTachyonExceptionorg.apache.thrift.TExceptionlong user_createNewBlock(int fileId)
throws FileDoesNotExistException,
org.apache.thrift.TException
FileDoesNotExistExceptionorg.apache.thrift.TExceptionvoid user_completeFile(int fileId)
throws FileDoesNotExistException,
org.apache.thrift.TException
FileDoesNotExistExceptionorg.apache.thrift.TExceptionint user_getFileId(String path) throws InvalidPathException, org.apache.thrift.TException
path - InvalidPathExceptionorg.apache.thrift.TExceptionlong user_getUserId()
throws org.apache.thrift.TException
org.apache.thrift.TExceptionlong user_getBlockId(int fileId,
int index)
throws FileDoesNotExistException,
org.apache.thrift.TException
FileDoesNotExistExceptionorg.apache.thrift.TExceptionNetAddress user_getWorker(boolean random, String host) throws NoWorkerException, org.apache.thrift.TException
random - host - NoWorkerExceptionorg.apache.thrift.TExceptionClientFileInfo getClientFileInfoById(int fileId) throws FileDoesNotExistException, org.apache.thrift.TException
FileDoesNotExistExceptionorg.apache.thrift.TExceptionClientFileInfo user_getClientFileInfoByPath(String path) throws FileDoesNotExistException, InvalidPathException, org.apache.thrift.TException
FileDoesNotExistExceptionInvalidPathExceptionorg.apache.thrift.TExceptionClientBlockInfo user_getClientBlockInfo(long blockId) throws FileDoesNotExistException, BlockInfoException, org.apache.thrift.TException
blockId - FileDoesNotExistExceptionBlockInfoExceptionorg.apache.thrift.TExceptionList<ClientBlockInfo> user_getFileBlocksById(int fileId) throws FileDoesNotExistException, org.apache.thrift.TException
fileId - FileDoesNotExistExceptionorg.apache.thrift.TExceptionList<ClientBlockInfo> user_getFileBlocksByPath(String path) throws FileDoesNotExistException, InvalidPathException, org.apache.thrift.TException
path - FileDoesNotExistExceptionInvalidPathExceptionorg.apache.thrift.TExceptionList<Integer> user_listFiles(String path, boolean recursive) throws FileDoesNotExistException, InvalidPathException, org.apache.thrift.TException
FileDoesNotExistExceptionInvalidPathExceptionorg.apache.thrift.TExceptionList<String> user_ls(String path, boolean recursive) throws FileDoesNotExistException, InvalidPathException, org.apache.thrift.TException
FileDoesNotExistExceptionInvalidPathExceptionorg.apache.thrift.TExceptionboolean user_deleteById(int fileId,
boolean recursive)
throws TachyonException,
org.apache.thrift.TException
TachyonExceptionorg.apache.thrift.TExceptionboolean user_deleteByPath(String path, boolean recursive) throws TachyonException, org.apache.thrift.TException
TachyonExceptionorg.apache.thrift.TExceptionvoid user_outOfMemoryForPinFile(int fileId)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionvoid user_rename(String srcPath, String dstPath) throws FileAlreadyExistException, FileDoesNotExistException, InvalidPathException, org.apache.thrift.TException
FileAlreadyExistExceptionFileDoesNotExistExceptionInvalidPathExceptionorg.apache.thrift.TExceptionvoid user_renameTo(int fileId,
String dstPath)
throws FileAlreadyExistException,
FileDoesNotExistException,
InvalidPathException,
org.apache.thrift.TException
FileAlreadyExistExceptionFileDoesNotExistExceptionInvalidPathExceptionorg.apache.thrift.TExceptionvoid user_unpinFile(int fileId)
throws FileDoesNotExistException,
org.apache.thrift.TException
FileDoesNotExistExceptionorg.apache.thrift.TExceptionboolean user_mkdir(String path) throws FileAlreadyExistException, InvalidPathException, TachyonException, org.apache.thrift.TException
FileAlreadyExistExceptionInvalidPathExceptionTachyonExceptionorg.apache.thrift.TExceptionint user_createRawTable(String path, int columns, ByteBuffer metadata) throws FileAlreadyExistException, InvalidPathException, TableColumnException, TachyonException, org.apache.thrift.TException
FileAlreadyExistExceptionInvalidPathExceptionTableColumnExceptionTachyonExceptionorg.apache.thrift.TExceptionint user_getRawTableId(String path) throws InvalidPathException, org.apache.thrift.TException
InvalidPathExceptionorg.apache.thrift.TExceptionClientRawTableInfo user_getClientRawTableInfoById(int tableId) throws TableDoesNotExistException, org.apache.thrift.TException
TableDoesNotExistExceptionorg.apache.thrift.TExceptionClientRawTableInfo user_getClientRawTableInfoByPath(String tablePath) throws TableDoesNotExistException, InvalidPathException, org.apache.thrift.TException
TableDoesNotExistExceptionInvalidPathExceptionorg.apache.thrift.TExceptionvoid user_updateRawTableMetadata(int tableId,
ByteBuffer metadata)
throws TableDoesNotExistException,
TachyonException,
org.apache.thrift.TException
TableDoesNotExistExceptionTachyonExceptionorg.apache.thrift.TExceptionint user_getNumberOfFiles(String path) throws FileDoesNotExistException, InvalidPathException, org.apache.thrift.TException
FileDoesNotExistExceptionInvalidPathExceptionorg.apache.thrift.TExceptionString user_getUnderfsAddress() throws org.apache.thrift.TException
org.apache.thrift.TExceptionCopyright © 2014. All rights reserved.