public static class MasterService.AsyncClient extends org.apache.thrift.async.TAsyncClient implements MasterService.AsyncIface
Constructor and Description |
---|
AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.async.TAsyncClientManager clientManager,
org.apache.thrift.transport.TNonblockingTransport transport) |
Modifier and Type | Method and Description |
---|---|
void |
addCheckpoint(long workerId,
int fileId,
long length,
String checkpointPath,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.addCheckpoint_call> resultHandler) |
void |
getClientFileInfoById(int fileId,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.getClientFileInfoById_call> resultHandler) |
void |
getWorkersInfo(org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.getWorkersInfo_call> resultHandler) |
void |
liststatus(String path,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.liststatus_call> resultHandler) |
void |
user_completeFile(int fileId,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_completeFile_call> 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<MasterService.AsyncClient.user_createDependency_call> resultHandler) |
void |
user_createFile(String path,
long blockSizeByte,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_createFile_call> resultHandler) |
void |
user_createFileOnCheckpoint(String path,
String checkpointPath,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_createFileOnCheckpoint_call> resultHandler) |
void |
user_createNewBlock(int fileId,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_createNewBlock_call> resultHandler) |
void |
user_createRawTable(String path,
int columns,
ByteBuffer metadata,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_createRawTable_call> resultHandler) |
void |
user_deleteById(int fileId,
boolean recursive,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_deleteById_call> resultHandler) |
void |
user_deleteByPath(String path,
boolean recursive,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_deleteByPath_call> resultHandler) |
void |
user_getBlockId(int fileId,
int index,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getBlockId_call> resultHandler) |
void |
user_getClientBlockInfo(long blockId,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getClientBlockInfo_call> resultHandler) |
void |
user_getClientDependencyInfo(int dependencyId,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getClientDependencyInfo_call> resultHandler) |
void |
user_getClientFileInfoByPath(String path,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getClientFileInfoByPath_call> resultHandler) |
void |
user_getClientRawTableInfoById(int tableId,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getClientRawTableInfoById_call> resultHandler) |
void |
user_getClientRawTableInfoByPath(String tablePath,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getClientRawTableInfoByPath_call> resultHandler) |
void |
user_getFileBlocksById(int fileId,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getFileBlocksById_call> resultHandler) |
void |
user_getFileBlocksByPath(String path,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getFileBlocksByPath_call> resultHandler) |
void |
user_getFileId(String path,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getFileId_call> resultHandler) |
void |
user_getNumberOfFiles(String path,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getNumberOfFiles_call> resultHandler) |
void |
user_getRawTableId(String path,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getRawTableId_call> resultHandler) |
void |
user_getUnderfsAddress(org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getUnderfsAddress_call> resultHandler) |
void |
user_getUserId(org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getUserId_call> resultHandler) |
void |
user_getWorker(boolean random,
String host,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getWorker_call> resultHandler) |
void |
user_listFiles(String path,
boolean recursive,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_listFiles_call> resultHandler) |
void |
user_ls(String path,
boolean recursive,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_ls_call> resultHandler) |
void |
user_mkdir(String path,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_mkdir_call> resultHandler) |
void |
user_outOfMemoryForPinFile(int fileId,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_outOfMemoryForPinFile_call> resultHandler) |
void |
user_rename(String srcPath,
String dstPath,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_rename_call> resultHandler) |
void |
user_renameTo(int fileId,
String dstPath,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_renameTo_call> resultHandler) |
void |
user_reportLostFile(int fileId,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_reportLostFile_call> resultHandler) |
void |
user_requestFilesInDependency(int depId,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_requestFilesInDependency_call> resultHandler) |
void |
user_setPinned(int fileId,
boolean pinned,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_setPinned_call> resultHandler) |
void |
user_updateRawTableMetadata(int tableId,
ByteBuffer metadata,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_updateRawTableMetadata_call> resultHandler) |
void |
worker_cacheBlock(long workerId,
long workerUsedBytes,
long blockId,
long length,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.worker_cacheBlock_call> resultHandler) |
void |
worker_getPinIdList(org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.worker_getPinIdList_call> resultHandler) |
void |
worker_getPriorityDependencyList(org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.worker_getPriorityDependencyList_call> resultHandler) |
void |
worker_heartbeat(long workerId,
long usedBytes,
List<Long> removedBlocks,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.worker_heartbeat_call> resultHandler) |
void |
worker_register(NetAddress workerNetAddress,
long totalBytes,
long usedBytes,
List<Long> currentBlocks,
org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.worker_register_call> resultHandler) |
public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport)
public void addCheckpoint(long workerId, int fileId, long length, String checkpointPath, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.addCheckpoint_call> resultHandler) throws org.apache.thrift.TException
addCheckpoint
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void getWorkersInfo(org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.getWorkersInfo_call> resultHandler) throws org.apache.thrift.TException
getWorkersInfo
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void liststatus(String path, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.liststatus_call> resultHandler) throws org.apache.thrift.TException
liststatus
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void worker_register(NetAddress workerNetAddress, long totalBytes, long usedBytes, List<Long> currentBlocks, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.worker_register_call> resultHandler) throws org.apache.thrift.TException
worker_register
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void worker_heartbeat(long workerId, long usedBytes, List<Long> removedBlocks, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.worker_heartbeat_call> resultHandler) throws org.apache.thrift.TException
worker_heartbeat
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void worker_cacheBlock(long workerId, long workerUsedBytes, long blockId, long length, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.worker_cacheBlock_call> resultHandler) throws org.apache.thrift.TException
worker_cacheBlock
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void worker_getPinIdList(org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.worker_getPinIdList_call> resultHandler) throws org.apache.thrift.TException
worker_getPinIdList
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void worker_getPriorityDependencyList(org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.worker_getPriorityDependencyList_call> resultHandler) throws org.apache.thrift.TException
worker_getPriorityDependencyList
in interface MasterService.AsyncIface
org.apache.thrift.TException
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<MasterService.AsyncClient.user_createDependency_call> resultHandler) throws org.apache.thrift.TException
user_createDependency
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getClientDependencyInfo(int dependencyId, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getClientDependencyInfo_call> resultHandler) throws org.apache.thrift.TException
user_getClientDependencyInfo
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_reportLostFile(int fileId, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_reportLostFile_call> resultHandler) throws org.apache.thrift.TException
user_reportLostFile
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_requestFilesInDependency(int depId, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_requestFilesInDependency_call> resultHandler) throws org.apache.thrift.TException
user_requestFilesInDependency
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_createFile(String path, long blockSizeByte, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_createFile_call> resultHandler) throws org.apache.thrift.TException
user_createFile
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_createFileOnCheckpoint(String path, String checkpointPath, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_createFileOnCheckpoint_call> resultHandler) throws org.apache.thrift.TException
user_createFileOnCheckpoint
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_createNewBlock(int fileId, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_createNewBlock_call> resultHandler) throws org.apache.thrift.TException
user_createNewBlock
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_completeFile(int fileId, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_completeFile_call> resultHandler) throws org.apache.thrift.TException
user_completeFile
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getFileId(String path, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getFileId_call> resultHandler) throws org.apache.thrift.TException
user_getFileId
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getUserId(org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getUserId_call> resultHandler) throws org.apache.thrift.TException
user_getUserId
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getBlockId(int fileId, int index, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getBlockId_call> resultHandler) throws org.apache.thrift.TException
user_getBlockId
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getWorker(boolean random, String host, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getWorker_call> resultHandler) throws org.apache.thrift.TException
user_getWorker
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void getClientFileInfoById(int fileId, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.getClientFileInfoById_call> resultHandler) throws org.apache.thrift.TException
getClientFileInfoById
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getClientFileInfoByPath(String path, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getClientFileInfoByPath_call> resultHandler) throws org.apache.thrift.TException
user_getClientFileInfoByPath
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getClientBlockInfo(long blockId, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getClientBlockInfo_call> resultHandler) throws org.apache.thrift.TException
user_getClientBlockInfo
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getFileBlocksById(int fileId, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getFileBlocksById_call> resultHandler) throws org.apache.thrift.TException
user_getFileBlocksById
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getFileBlocksByPath(String path, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getFileBlocksByPath_call> resultHandler) throws org.apache.thrift.TException
user_getFileBlocksByPath
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_listFiles(String path, boolean recursive, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_listFiles_call> resultHandler) throws org.apache.thrift.TException
user_listFiles
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_ls(String path, boolean recursive, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_ls_call> resultHandler) throws org.apache.thrift.TException
user_ls
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_deleteById(int fileId, boolean recursive, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_deleteById_call> resultHandler) throws org.apache.thrift.TException
user_deleteById
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_deleteByPath(String path, boolean recursive, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_deleteByPath_call> resultHandler) throws org.apache.thrift.TException
user_deleteByPath
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_outOfMemoryForPinFile(int fileId, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_outOfMemoryForPinFile_call> resultHandler) throws org.apache.thrift.TException
user_outOfMemoryForPinFile
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_rename(String srcPath, String dstPath, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_rename_call> resultHandler) throws org.apache.thrift.TException
user_rename
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_renameTo(int fileId, String dstPath, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_renameTo_call> resultHandler) throws org.apache.thrift.TException
user_renameTo
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_setPinned(int fileId, boolean pinned, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_setPinned_call> resultHandler) throws org.apache.thrift.TException
user_setPinned
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_mkdir(String path, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_mkdir_call> resultHandler) throws org.apache.thrift.TException
user_mkdir
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_createRawTable(String path, int columns, ByteBuffer metadata, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_createRawTable_call> resultHandler) throws org.apache.thrift.TException
user_createRawTable
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getRawTableId(String path, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getRawTableId_call> resultHandler) throws org.apache.thrift.TException
user_getRawTableId
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getClientRawTableInfoById(int tableId, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getClientRawTableInfoById_call> resultHandler) throws org.apache.thrift.TException
user_getClientRawTableInfoById
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getClientRawTableInfoByPath(String tablePath, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getClientRawTableInfoByPath_call> resultHandler) throws org.apache.thrift.TException
user_getClientRawTableInfoByPath
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_updateRawTableMetadata(int tableId, ByteBuffer metadata, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_updateRawTableMetadata_call> resultHandler) throws org.apache.thrift.TException
user_updateRawTableMetadata
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getNumberOfFiles(String path, org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getNumberOfFiles_call> resultHandler) throws org.apache.thrift.TException
user_getNumberOfFiles
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getUnderfsAddress(org.apache.thrift.async.AsyncMethodCallback<MasterService.AsyncClient.user_getUnderfsAddress_call> resultHandler) throws org.apache.thrift.TException
user_getUnderfsAddress
in interface MasterService.AsyncIface
org.apache.thrift.TException
Copyright © 2014. All rights reserved.