tachyon.thrift

Interface MasterService.AsyncIface

All Known Implementing Classes:

MasterService.AsyncClient

Enclosing class:

MasterService

public static interface MasterService.AsyncIface

Method Summary

Methods

Modifier and Type	Method and Description
void	addCheckpoint(long workerId, int fileId, long length, String checkpointPath, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getFileStatus(int fileId, String path, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	getWorkersInfo(org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	liststatus(String path, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_completeFile(int fileId, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_createDependency(List<String> parents, List<String> children, String commandPrefix, List<ByteBuffer> data, String comment, String framework, String frameworkVersion, int dependencyType, long childrenBlockSizeByte, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_createFile(String path, String ufsPath, long blockSizeByte, boolean recursive, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_createNewBlock(int fileId, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_createRawTable(String path, int columns, ByteBuffer metadata, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_delete(int fileId, String path, boolean recursive, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_freepath(int fileId, String path, boolean recursive, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_getBlockId(int fileId, int index, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_getClientBlockInfo(long blockId, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_getClientDependencyInfo(int dependencyId, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_getClientRawTableInfo(int id, String path, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_getFileBlocks(int fileId, String path, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_getRawTableId(String path, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_getUfsAddress(org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_getUserId(org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_getWorker(boolean random, String host, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_heartbeat(org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_mkdirs(String path, boolean recursive, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_rename(int fileId, String srcPath, String dstPath, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_reportLostFile(int fileId, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_requestFilesInDependency(int depId, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_setPinned(int fileId, boolean pinned, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	user_updateRawTableMetadata(int tableId, ByteBuffer metadata, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	worker_cacheBlock(long workerId, long workerUsedBytes, long storageDirId, long blockId, long length, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	worker_getPinIdList(org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	worker_getPriorityDependencyList(org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	worker_heartbeat(long workerId, long usedBytes, List<Long> removedBlockIds, Map<Long,List<Long>> addedBlockIds, org.apache.thrift.async.AsyncMethodCallback resultHandler)
void	worker_register(NetAddress workerNetAddress, long totalBytes, long usedBytes, Map<Long,List<Long>> currentBlocks, org.apache.thrift.async.AsyncMethodCallback resultHandler)

Method Detail

addCheckpoint

void addCheckpoint(long workerId,
                 int fileId,
                 long length,
                 String checkpointPath,
                 org.apache.thrift.async.AsyncMethodCallback resultHandler)
                   throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

getWorkersInfo

void getWorkersInfo(org.apache.thrift.async.AsyncMethodCallback resultHandler)
                    throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

liststatus

void liststatus(String path,
              org.apache.thrift.async.AsyncMethodCallback resultHandler)
                throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

worker_register

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

Throws:

org.apache.thrift.TException

worker_heartbeat

void worker_heartbeat(long workerId,
                    long usedBytes,
                    List<Long> removedBlockIds,
                    Map<Long,List<Long>> addedBlockIds,
                    org.apache.thrift.async.AsyncMethodCallback resultHandler)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

worker_cacheBlock

void worker_cacheBlock(long workerId,
                     long workerUsedBytes,
                     long storageDirId,
                     long blockId,
                     long length,
                     org.apache.thrift.async.AsyncMethodCallback resultHandler)
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

worker_getPinIdList

void worker_getPinIdList(org.apache.thrift.async.AsyncMethodCallback resultHandler)
                         throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

worker_getPriorityDependencyList

void worker_getPriorityDependencyList(org.apache.thrift.async.AsyncMethodCallback resultHandler)
                                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_createDependency

void user_createDependency(List<String> parents,
                         List<String> children,
                         String commandPrefix,
                         List<ByteBuffer> data,
                         String comment,
                         String framework,
                         String frameworkVersion,
                         int dependencyType,
                         long childrenBlockSizeByte,
                         org.apache.thrift.async.AsyncMethodCallback resultHandler)
                           throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_getClientDependencyInfo

void user_getClientDependencyInfo(int dependencyId,
                                org.apache.thrift.async.AsyncMethodCallback resultHandler)
                                  throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_reportLostFile

void user_reportLostFile(int fileId,
                       org.apache.thrift.async.AsyncMethodCallback resultHandler)
                         throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_requestFilesInDependency

void user_requestFilesInDependency(int depId,
                                 org.apache.thrift.async.AsyncMethodCallback resultHandler)
                                   throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_createFile

void user_createFile(String path,
                   String ufsPath,
                   long blockSizeByte,
                   boolean recursive,
                   org.apache.thrift.async.AsyncMethodCallback resultHandler)
                     throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_createNewBlock

void user_createNewBlock(int fileId,
                       org.apache.thrift.async.AsyncMethodCallback resultHandler)
                         throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_completeFile

void user_completeFile(int fileId,
                     org.apache.thrift.async.AsyncMethodCallback resultHandler)
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_getUserId

void user_getUserId(org.apache.thrift.async.AsyncMethodCallback resultHandler)
                    throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_getBlockId

void user_getBlockId(int fileId,
                   int index,
                   org.apache.thrift.async.AsyncMethodCallback resultHandler)
                     throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_getWorker

void user_getWorker(boolean random,
                  String host,
                  org.apache.thrift.async.AsyncMethodCallback resultHandler)
                    throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

getFileStatus

void getFileStatus(int fileId,
                 String path,
                 org.apache.thrift.async.AsyncMethodCallback resultHandler)
                   throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_getClientBlockInfo

void user_getClientBlockInfo(long blockId,
                           org.apache.thrift.async.AsyncMethodCallback resultHandler)
                             throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_getFileBlocks

void user_getFileBlocks(int fileId,
                      String path,
                      org.apache.thrift.async.AsyncMethodCallback resultHandler)
                        throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_delete

void user_delete(int fileId,
               String path,
               boolean recursive,
               org.apache.thrift.async.AsyncMethodCallback resultHandler)
                 throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_rename

void user_rename(int fileId,
               String srcPath,
               String dstPath,
               org.apache.thrift.async.AsyncMethodCallback resultHandler)
                 throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_setPinned

void user_setPinned(int fileId,
                  boolean pinned,
                  org.apache.thrift.async.AsyncMethodCallback resultHandler)
                    throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_mkdirs

void user_mkdirs(String path,
               boolean recursive,
               org.apache.thrift.async.AsyncMethodCallback resultHandler)
                 throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_createRawTable

void user_createRawTable(String path,
                       int columns,
                       ByteBuffer metadata,
                       org.apache.thrift.async.AsyncMethodCallback resultHandler)
                         throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_getRawTableId

void user_getRawTableId(String path,
                      org.apache.thrift.async.AsyncMethodCallback resultHandler)
                        throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_getClientRawTableInfo

void user_getClientRawTableInfo(int id,
                              String path,
                              org.apache.thrift.async.AsyncMethodCallback resultHandler)
                                throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_updateRawTableMetadata

void user_updateRawTableMetadata(int tableId,
                               ByteBuffer metadata,
                               org.apache.thrift.async.AsyncMethodCallback resultHandler)
                                 throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_getUfsAddress

void user_getUfsAddress(org.apache.thrift.async.AsyncMethodCallback resultHandler)
                        throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_heartbeat

void user_heartbeat(org.apache.thrift.async.AsyncMethodCallback resultHandler)
                    throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

user_freepath

void user_freepath(int fileId,
                 String path,
                 boolean recursive,
                 org.apache.thrift.async.AsyncMethodCallback resultHandler)
                   throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException