public static interface MasterService.AsyncIface
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) |
void addCheckpoint(long workerId, int fileId, long length, String checkpointPath, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void getWorkersInfo(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void liststatus(String path, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
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
org.apache.thrift.TException
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
org.apache.thrift.TException
void worker_cacheBlock(long workerId, long workerUsedBytes, long storageDirId, long blockId, long length, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void worker_getPinIdList(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void worker_getPriorityDependencyList(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
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
org.apache.thrift.TException
void user_getClientDependencyInfo(int dependencyId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_reportLostFile(int fileId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_requestFilesInDependency(int depId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_createFile(String path, String ufsPath, long blockSizeByte, boolean recursive, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_createNewBlock(int fileId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_completeFile(int fileId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_getUserId(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_getBlockId(int fileId, int index, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_getWorker(boolean random, String host, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void getFileStatus(int fileId, String path, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_getClientBlockInfo(long blockId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_getFileBlocks(int fileId, String path, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_delete(int fileId, String path, boolean recursive, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_rename(int fileId, String srcPath, String dstPath, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_setPinned(int fileId, boolean pinned, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_mkdirs(String path, boolean recursive, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_createRawTable(String path, int columns, ByteBuffer metadata, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_getRawTableId(String path, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_getClientRawTableInfo(int id, String path, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_updateRawTableMetadata(int tableId, ByteBuffer metadata, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_getUfsAddress(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_heartbeat(org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
void user_freepath(int fileId, String path, boolean recursive, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
org.apache.thrift.TException
Copyright © 2015. All Rights Reserved.