public static class MasterService.AsyncClient extends org.apache.thrift.async.TAsyncClient implements MasterService.AsyncIface
Constructor and Description |
---|
MasterService.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 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) |
public MasterService.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 resultHandler) throws org.apache.thrift.TException
addCheckpoint
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void getWorkersInfo(org.apache.thrift.async.AsyncMethodCallback 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 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, Map<Long,List<Long>> currentBlocks, org.apache.thrift.async.AsyncMethodCallback 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> removedBlockIds, Map<Long,List<Long>> addedBlockIds, org.apache.thrift.async.AsyncMethodCallback 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 storageDirId, long blockId, long length, org.apache.thrift.async.AsyncMethodCallback 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 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 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 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 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 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 resultHandler) throws org.apache.thrift.TException
user_requestFilesInDependency
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_createFile(String path, String ufsPath, long blockSizeByte, boolean recursive, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
user_createFile
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_createNewBlock(int fileId, org.apache.thrift.async.AsyncMethodCallback 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 resultHandler) throws org.apache.thrift.TException
user_completeFile
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getUserId(org.apache.thrift.async.AsyncMethodCallback 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 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 resultHandler) throws org.apache.thrift.TException
user_getWorker
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void getFileStatus(int fileId, String path, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
getFileStatus
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getClientBlockInfo(long blockId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
user_getClientBlockInfo
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getFileBlocks(int fileId, String path, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
user_getFileBlocks
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_delete(int fileId, String path, boolean recursive, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
user_delete
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_rename(int fileId, String srcPath, String dstPath, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
user_rename
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_setPinned(int fileId, boolean pinned, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
user_setPinned
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_mkdirs(String path, boolean recursive, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
user_mkdirs
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_createRawTable(String path, int columns, ByteBuffer metadata, org.apache.thrift.async.AsyncMethodCallback 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 resultHandler) throws org.apache.thrift.TException
user_getRawTableId
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getClientRawTableInfo(int id, String path, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
user_getClientRawTableInfo
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_updateRawTableMetadata(int tableId, ByteBuffer metadata, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
user_updateRawTableMetadata
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_getUfsAddress(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
user_getUfsAddress
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_heartbeat(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
user_heartbeat
in interface MasterService.AsyncIface
org.apache.thrift.TException
public void user_freepath(int fileId, String path, boolean recursive, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
user_freepath
in interface MasterService.AsyncIface
org.apache.thrift.TException
Copyright © 2015. All Rights Reserved.