public static class WorkerService.AsyncClient extends org.apache.thrift.async.TAsyncClient implements WorkerService.AsyncIface
Modifier and Type | Class and Description |
---|---|
static class |
WorkerService.AsyncClient.accessBlock_call |
static class |
WorkerService.AsyncClient.addCheckpoint_call |
static class |
WorkerService.AsyncClient.asyncCheckpoint_call |
static class |
WorkerService.AsyncClient.cacheBlock_call |
static class |
WorkerService.AsyncClient.cancelBlock_call |
static class |
WorkerService.AsyncClient.Factory |
static class |
WorkerService.AsyncClient.getUserUfsTempFolder_call |
static class |
WorkerService.AsyncClient.lockBlock_call |
static class |
WorkerService.AsyncClient.promoteBlock_call |
static class |
WorkerService.AsyncClient.requestBlockLocation_call |
static class |
WorkerService.AsyncClient.requestSpace_call |
static class |
WorkerService.AsyncClient.unlockBlock_call |
static class |
WorkerService.AsyncClient.userHeartbeat_call |
Constructor and Description |
---|
WorkerService.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 |
accessBlock(long blockId,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
addCheckpoint(long userId,
int fileId,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
asyncCheckpoint(int fileId,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
cacheBlock(long userId,
long blockId,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
cancelBlock(long userId,
long blockId,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
getUserUfsTempFolder(long userId,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
lockBlock(long blockId,
long userId,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
promoteBlock(long blockId,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
requestBlockLocation(long userId,
long blockId,
long initialBytes,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
requestSpace(long userId,
long blockId,
long requestBytes,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
unlockBlock(long blockId,
long userId,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
userHeartbeat(long userId,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
public WorkerService.AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport)
public void accessBlock(long blockId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
accessBlock
in interface WorkerService.AsyncIface
org.apache.thrift.TException
public void addCheckpoint(long userId, int fileId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
addCheckpoint
in interface WorkerService.AsyncIface
org.apache.thrift.TException
public void asyncCheckpoint(int fileId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
asyncCheckpoint
in interface WorkerService.AsyncIface
org.apache.thrift.TException
public void cacheBlock(long userId, long blockId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
cacheBlock
in interface WorkerService.AsyncIface
org.apache.thrift.TException
public void cancelBlock(long userId, long blockId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
cancelBlock
in interface WorkerService.AsyncIface
org.apache.thrift.TException
public void getUserUfsTempFolder(long userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
getUserUfsTempFolder
in interface WorkerService.AsyncIface
org.apache.thrift.TException
public void lockBlock(long blockId, long userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
lockBlock
in interface WorkerService.AsyncIface
org.apache.thrift.TException
public void promoteBlock(long blockId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
promoteBlock
in interface WorkerService.AsyncIface
org.apache.thrift.TException
public void requestBlockLocation(long userId, long blockId, long initialBytes, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
requestBlockLocation
in interface WorkerService.AsyncIface
org.apache.thrift.TException
public void requestSpace(long userId, long blockId, long requestBytes, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
requestSpace
in interface WorkerService.AsyncIface
org.apache.thrift.TException
public void unlockBlock(long blockId, long userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
unlockBlock
in interface WorkerService.AsyncIface
org.apache.thrift.TException
public void userHeartbeat(long userId, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException
userHeartbeat
in interface WorkerService.AsyncIface
org.apache.thrift.TException
Copyright © 2015. All Rights Reserved.