tachyon.thrift

Interface MasterService.Iface

All Known Implementing Classes:

MasterService.Client, MasterServiceHandler

Enclosing class:

MasterService

public static interface MasterService.Iface

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addCheckpoint(long workerId, int fileId, long length, String checkpointPath)
ClientFileInfo	getFileStatus(int fileId, String path)
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, String ufsPath, long blockSizeByte, boolean recursive)
long	user_createNewBlock(int fileId)
int	user_createRawTable(String path, int columns, ByteBuffer metadata)
boolean	user_delete(int fileId, String path, boolean recursive) Delete file
boolean	user_freepath(int fileId, 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)
ClientRawTableInfo	user_getClientRawTableInfo(int id, String path) Get RawTable's info; Return a ClientRawTable instance with id 0 if the system does not contain the table.
List<ClientBlockInfo>	user_getFileBlocks(int fileId, String path) Get file blocks info.
int	user_getRawTableId(String path) Return 0 if does not contain the Table, return fileId if it exists.
String	user_getUfsAddress()
long	user_getUserId()
NetAddress	user_getWorker(boolean random, String host) Get local worker NetAddress
void	user_heartbeat() Returns if the message was received.
boolean	user_mkdirs(String path, boolean recursive)
boolean	user_rename(int fileId, String srcPath, String dstPath)
void	user_reportLostFile(int fileId)
void	user_requestFilesInDependency(int depId)
void	user_setPinned(int fileId, boolean pinned)
void	user_updateRawTableMetadata(int tableId, ByteBuffer metadata)
void	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.
Set<Integer>	worker_getPinIdList()
List<Integer>	worker_getPriorityDependencyList()
Command	worker_heartbeat(long workerId, long usedBytes, List<Long> removedBlockIds, Map<Long,List<Long>> addedBlockIds) Heart beat between worker and master, worker update used Tachyon space in bytes, removed blocks and added blocks in each storage directory by eviction and promotion to master, and return the command from master to worker.
long	worker_register(NetAddress workerNetAddress, long totalBytes, long usedBytes, Map<Long,List<Long>> currentBlocks) Worker register and synch up capacity of Tachyon space, used space bytes and blocks in each storage directory to master, the return value rv % 100,000 is really workerId, rv / 1000,000 is master started time.

Method Detail

addCheckpoint

boolean addCheckpoint(long workerId,
                    int fileId,
                    long length,
                    String checkpointPath)
                      throws FileDoesNotExistException,
                             SuspectedFileSizeException,
                             BlockInfoException,
                             org.apache.thrift.TException

Throws:

FileDoesNotExistException

SuspectedFileSizeException

BlockInfoException

org.apache.thrift.TException

getWorkersInfo

List<ClientWorkerInfo> getWorkersInfo()
                                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

liststatus

List<ClientFileInfo> liststatus(String path)
                                throws InvalidPathException,
                                       FileDoesNotExistException,
                                       org.apache.thrift.TException

Throws:

InvalidPathException

FileDoesNotExistException

org.apache.thrift.TException

worker_register

long worker_register(NetAddress workerNetAddress,
                   long totalBytes,
                   long usedBytes,
                   Map<Long,List<Long>> currentBlocks)
                     throws BlockInfoException,
                            org.apache.thrift.TException

Worker register and synch up capacity of Tachyon space, used space bytes and blocks in each storage directory to master, the return value rv % 100,000 is really workerId, rv / 1000,000 is master started time. currentBlocks maps from id of storage directory to the blocks it contains.

Parameters:

workerNetAddress -

totalBytes -

usedBytes -

currentBlocks -

Throws:

BlockInfoException

org.apache.thrift.TException

worker_heartbeat

Command worker_heartbeat(long workerId,
                       long usedBytes,
                       List<Long> removedBlockIds,
                       Map<Long,List<Long>> addedBlockIds)
                         throws BlockInfoException,
                                org.apache.thrift.TException

Heart beat between worker and master, worker update used Tachyon space in bytes, removed blocks and added blocks in each storage directory by eviction and promotion to master, and return the command from master to worker. addedBlockIds maps from id of storage directory to the blocks added in it.

Parameters:

workerId -

usedBytes -

removedBlockIds -

addedBlockIds -

Throws:

BlockInfoException

org.apache.thrift.TException

worker_cacheBlock

void worker_cacheBlock(long workerId,
                     long workerUsedBytes,
                     long storageDirId,
                     long blockId,
                     long length)
                       throws FileDoesNotExistException,
                              SuspectedFileSizeException,
                              BlockInfoException,
                              org.apache.thrift.TException

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.

Parameters:

workerId -

workerUsedBytes -

storageDirId -

blockId -

length -

Throws:

FileDoesNotExistException

SuspectedFileSizeException

BlockInfoException

org.apache.thrift.TException

worker_getPinIdList

Set<Integer> worker_getPinIdList()
                                 throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

worker_getPriorityDependencyList

List<Integer> worker_getPriorityDependencyList()
                                               throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_createDependency

int 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

Throws:

InvalidPathException

FileDoesNotExistException

FileAlreadyExistException

BlockInfoException

TachyonException

org.apache.thrift.TException

user_getClientDependencyInfo

ClientDependencyInfo user_getClientDependencyInfo(int dependencyId)
                                                  throws DependencyDoesNotExistException,
                                                         org.apache.thrift.TException

Throws:

DependencyDoesNotExistException

org.apache.thrift.TException

user_reportLostFile

void user_reportLostFile(int fileId)
                         throws FileDoesNotExistException,
                                org.apache.thrift.TException

Throws:

FileDoesNotExistException

org.apache.thrift.TException

user_requestFilesInDependency

void user_requestFilesInDependency(int depId)
                                   throws DependencyDoesNotExistException,
                                          org.apache.thrift.TException

Throws:

DependencyDoesNotExistException

org.apache.thrift.TException

user_createFile

int user_createFile(String path,
                  String ufsPath,
                  long blockSizeByte,
                  boolean recursive)
                    throws FileAlreadyExistException,
                           InvalidPathException,
                           BlockInfoException,
                           SuspectedFileSizeException,
                           TachyonException,
                           org.apache.thrift.TException

Throws:

FileAlreadyExistException

InvalidPathException

BlockInfoException

SuspectedFileSizeException

TachyonException

org.apache.thrift.TException

user_createNewBlock

long user_createNewBlock(int fileId)
                         throws FileDoesNotExistException,
                                org.apache.thrift.TException

Throws:

FileDoesNotExistException

org.apache.thrift.TException

user_completeFile

void user_completeFile(int fileId)
                       throws FileDoesNotExistException,
                              org.apache.thrift.TException

Throws:

FileDoesNotExistException

org.apache.thrift.TException

user_getUserId

long user_getUserId()
                    throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_getBlockId

long user_getBlockId(int fileId,
                   int index)
                     throws FileDoesNotExistException,
                            org.apache.thrift.TException

Throws:

FileDoesNotExistException

org.apache.thrift.TException

user_getWorker

NetAddress user_getWorker(boolean random,
                        String host)
                          throws NoWorkerException,
                                 org.apache.thrift.TException

Get local worker NetAddress

Parameters:

random -

host -

Throws:

NoWorkerException

org.apache.thrift.TException

getFileStatus

ClientFileInfo getFileStatus(int fileId,
                           String path)
                             throws InvalidPathException,
                                    org.apache.thrift.TException

Throws:

InvalidPathException

org.apache.thrift.TException

user_getClientBlockInfo

ClientBlockInfo user_getClientBlockInfo(long blockId)
                                        throws FileDoesNotExistException,
                                               BlockInfoException,
                                               org.apache.thrift.TException

Get block's ClientBlockInfo.

Parameters:

blockId -

Throws:

FileDoesNotExistException

BlockInfoException

org.apache.thrift.TException

user_getFileBlocks

List<ClientBlockInfo> user_getFileBlocks(int fileId,
                                       String path)
                                         throws FileDoesNotExistException,
                                                InvalidPathException,
                                                org.apache.thrift.TException

Get file blocks info.

Parameters:

fileId -

path -

Throws:

FileDoesNotExistException

InvalidPathException

org.apache.thrift.TException

user_delete

boolean user_delete(int fileId,
                  String path,
                  boolean recursive)
                    throws TachyonException,
                           org.apache.thrift.TException

Delete file

Parameters:

fileId -

path -

recursive -

Throws:

TachyonException

org.apache.thrift.TException

user_rename

boolean user_rename(int fileId,
                  String srcPath,
                  String dstPath)
                    throws FileAlreadyExistException,
                           FileDoesNotExistException,
                           InvalidPathException,
                           org.apache.thrift.TException

Throws:

FileAlreadyExistException

FileDoesNotExistException

InvalidPathException

org.apache.thrift.TException

user_setPinned

void user_setPinned(int fileId,
                  boolean pinned)
                    throws FileDoesNotExistException,
                           org.apache.thrift.TException

Throws:

FileDoesNotExistException

org.apache.thrift.TException

user_mkdirs

boolean user_mkdirs(String path,
                  boolean recursive)
                    throws FileAlreadyExistException,
                           InvalidPathException,
                           TachyonException,
                           org.apache.thrift.TException

Throws:

FileAlreadyExistException

InvalidPathException

TachyonException

org.apache.thrift.TException

user_createRawTable

int user_createRawTable(String path,
                      int columns,
                      ByteBuffer metadata)
                        throws FileAlreadyExistException,
                               InvalidPathException,
                               TableColumnException,
                               TachyonException,
                               org.apache.thrift.TException

Throws:

FileAlreadyExistException

InvalidPathException

TableColumnException

TachyonException

org.apache.thrift.TException

user_getRawTableId

int user_getRawTableId(String path)
                       throws InvalidPathException,
                              org.apache.thrift.TException

Return 0 if does not contain the Table, return fileId if it exists.

Parameters:

path -

Throws:

InvalidPathException

org.apache.thrift.TException

user_getClientRawTableInfo

ClientRawTableInfo user_getClientRawTableInfo(int id,
                                            String path)
                                              throws TableDoesNotExistException,
                                                     InvalidPathException,
                                                     org.apache.thrift.TException

Get RawTable's info; Return a ClientRawTable instance with id 0 if the system does not contain the table. path if valid iff id is -1.

Parameters:

id -

path -

Throws:

TableDoesNotExistException

InvalidPathException

org.apache.thrift.TException

user_updateRawTableMetadata

void user_updateRawTableMetadata(int tableId,
                               ByteBuffer metadata)
                                 throws TableDoesNotExistException,
                                        TachyonException,
                                        org.apache.thrift.TException

Throws:

TableDoesNotExistException

TachyonException

org.apache.thrift.TException

user_getUfsAddress

String user_getUfsAddress()
                          throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_heartbeat

void user_heartbeat()
                    throws org.apache.thrift.TException

Returns if the message was received. Intended to check if the client can still connect to the master.

Throws:

org.apache.thrift.TException

user_freepath

boolean user_freepath(int fileId,
                    String path,
                    boolean recursive)
                      throws FileDoesNotExistException,
                             org.apache.thrift.TException

Throws:

FileDoesNotExistException

org.apache.thrift.TException