tachyon.thrift

Class MasterService.AsyncClient

java.lang.Object

org.apache.thrift.async.TAsyncClient

tachyon.thrift.MasterService.AsyncClient

All Implemented Interfaces:

MasterService.AsyncIface

Enclosing class:

MasterService

public static class MasterService.AsyncClient
extends org.apache.thrift.async.TAsyncClient
implements MasterService.AsyncIface

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MasterService.AsyncClient.addCheckpoint_call
static class	MasterService.AsyncClient.Factory
static class	MasterService.AsyncClient.getFileStatus_call
static class	MasterService.AsyncClient.getWorkersInfo_call
static class	MasterService.AsyncClient.liststatus_call
static class	MasterService.AsyncClient.user_completeFile_call
static class	MasterService.AsyncClient.user_createDependency_call
static class	MasterService.AsyncClient.user_createFile_call
static class	MasterService.AsyncClient.user_createNewBlock_call
static class	MasterService.AsyncClient.user_createRawTable_call
static class	MasterService.AsyncClient.user_delete_call
static class	MasterService.AsyncClient.user_freepath_call
static class	MasterService.AsyncClient.user_getBlockId_call
static class	MasterService.AsyncClient.user_getClientBlockInfo_call
static class	MasterService.AsyncClient.user_getClientDependencyInfo_call
static class	MasterService.AsyncClient.user_getClientRawTableInfo_call
static class	MasterService.AsyncClient.user_getFileBlocks_call
static class	MasterService.AsyncClient.user_getRawTableId_call
static class	MasterService.AsyncClient.user_getUfsAddress_call
static class	MasterService.AsyncClient.user_getUserId_call
static class	MasterService.AsyncClient.user_getWorker_call
static class	MasterService.AsyncClient.user_heartbeat_call
static class	MasterService.AsyncClient.user_mkdirs_call
static class	MasterService.AsyncClient.user_rename_call
static class	MasterService.AsyncClient.user_reportLostFile_call
static class	MasterService.AsyncClient.user_requestFilesInDependency_call
static class	MasterService.AsyncClient.user_setPinned_call
static class	MasterService.AsyncClient.user_updateRawTableMetadata_call
static class	MasterService.AsyncClient.worker_cacheBlock_call
static class	MasterService.AsyncClient.worker_getPinIdList_call
static class	MasterService.AsyncClient.worker_getPriorityDependencyList_call
static class	MasterService.AsyncClient.worker_heartbeat_call
static class	MasterService.AsyncClient.worker_register_call

Field Summary

Fields inherited from class org.apache.thrift.async.TAsyncClient

___currentMethod, ___manager, ___protocolFactory, ___transport

Constructor Summary

Constructors

Constructor and Description
MasterService.AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport)

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)

Methods inherited from class org.apache.thrift.async.TAsyncClient

checkReady, getError, getProtocolFactory, getTimeout, hasError, hasTimeout, onComplete, onError, setTimeout

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MasterService.AsyncClient

public MasterService.AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory,
                         org.apache.thrift.async.TAsyncClientManager clientManager,
                         org.apache.thrift.transport.TNonblockingTransport transport)

Method Detail

addCheckpoint

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

Specified by:

addCheckpoint in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

getWorkersInfo

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

Specified by:

getWorkersInfo in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

liststatus

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

Specified by:

liststatus in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

worker_register

public 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

Specified by:

worker_register in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

worker_heartbeat

public 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

Specified by:

worker_heartbeat in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

worker_cacheBlock

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

Specified by:

worker_cacheBlock in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

worker_getPinIdList

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

Specified by:

worker_getPinIdList in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

worker_getPriorityDependencyList

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

Specified by:

worker_getPriorityDependencyList in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_createDependency

public 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

Specified by:

user_createDependency in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_getClientDependencyInfo

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

Specified by:

user_getClientDependencyInfo in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_reportLostFile

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

Specified by:

user_reportLostFile in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_requestFilesInDependency

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

Specified by:

user_requestFilesInDependency in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_createFile

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

Specified by:

user_createFile in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_createNewBlock

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

Specified by:

user_createNewBlock in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_completeFile

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

Specified by:

user_completeFile in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_getUserId

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

Specified by:

user_getUserId in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_getBlockId

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

Specified by:

user_getBlockId in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_getWorker

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

Specified by:

user_getWorker in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

getFileStatus

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

Specified by:

getFileStatus in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_getClientBlockInfo

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

Specified by:

user_getClientBlockInfo in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_getFileBlocks

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

Specified by:

user_getFileBlocks in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_delete

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

Specified by:

user_delete in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_rename

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

Specified by:

user_rename in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_setPinned

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

Specified by:

user_setPinned in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_mkdirs

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

Specified by:

user_mkdirs in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_createRawTable

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

Specified by:

user_createRawTable in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_getRawTableId

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

Specified by:

user_getRawTableId in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_getClientRawTableInfo

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

Specified by:

user_getClientRawTableInfo in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_updateRawTableMetadata

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

Specified by:

user_updateRawTableMetadata in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_getUfsAddress

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

Specified by:

user_getUfsAddress in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_heartbeat

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

Specified by:

user_heartbeat in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException

user_freepath

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

Specified by:

user_freepath in interface MasterService.AsyncIface

Throws:

org.apache.thrift.TException