public static class WorkerService.Client extends org.apache.thrift.TServiceClient implements WorkerService.Iface
| Modifier and Type | Class and Description |
|---|---|
static class |
WorkerService.Client.Factory |
| Constructor and Description |
|---|
WorkerService.Client(org.apache.thrift.protocol.TProtocol prot) |
WorkerService.Client(org.apache.thrift.protocol.TProtocol iprot,
org.apache.thrift.protocol.TProtocol oprot) |
| Modifier and Type | Method and Description |
|---|---|
void |
accessBlock(long blockId) |
void |
addCheckpoint(long userId,
int fileId) |
boolean |
asyncCheckpoint(int fileId) |
void |
cacheBlock(long userId,
long blockId) |
String |
getDataFolder() |
String |
getUserTempFolder(long userId) |
String |
getUserUnderfsTempFolder(long userId) |
void |
lockBlock(long blockId,
long userId) |
void |
recv_accessBlock() |
void |
recv_addCheckpoint() |
boolean |
recv_asyncCheckpoint() |
void |
recv_cacheBlock() |
String |
recv_getDataFolder() |
String |
recv_getUserTempFolder() |
String |
recv_getUserUnderfsTempFolder() |
void |
recv_lockBlock() |
boolean |
recv_requestSpace() |
void |
recv_returnSpace() |
void |
recv_unlockBlock() |
void |
recv_userHeartbeat() |
boolean |
requestSpace(long userId,
long requestBytes) |
void |
returnSpace(long userId,
long returnedBytes) |
void |
send_accessBlock(long blockId) |
void |
send_addCheckpoint(long userId,
int fileId) |
void |
send_asyncCheckpoint(int fileId) |
void |
send_cacheBlock(long userId,
long blockId) |
void |
send_getDataFolder() |
void |
send_getUserTempFolder(long userId) |
void |
send_getUserUnderfsTempFolder(long userId) |
void |
send_lockBlock(long blockId,
long userId) |
void |
send_requestSpace(long userId,
long requestBytes) |
void |
send_returnSpace(long userId,
long returnedBytes) |
void |
send_unlockBlock(long blockId,
long userId) |
void |
send_userHeartbeat(long userId) |
void |
unlockBlock(long blockId,
long userId) |
void |
userHeartbeat(long userId) |
public WorkerService.Client(org.apache.thrift.protocol.TProtocol prot)
public WorkerService.Client(org.apache.thrift.protocol.TProtocol iprot,
org.apache.thrift.protocol.TProtocol oprot)
public void accessBlock(long blockId)
throws org.apache.thrift.TException
accessBlock in interface WorkerService.Ifaceorg.apache.thrift.TExceptionpublic void send_accessBlock(long blockId)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void recv_accessBlock()
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void addCheckpoint(long userId,
int fileId)
throws FileDoesNotExistException,
SuspectedFileSizeException,
FailedToCheckpointException,
BlockInfoException,
org.apache.thrift.TException
addCheckpoint in interface WorkerService.IfaceFileDoesNotExistExceptionSuspectedFileSizeExceptionFailedToCheckpointExceptionBlockInfoExceptionorg.apache.thrift.TExceptionpublic void send_addCheckpoint(long userId,
int fileId)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void recv_addCheckpoint()
throws FileDoesNotExistException,
SuspectedFileSizeException,
FailedToCheckpointException,
BlockInfoException,
org.apache.thrift.TException
FileDoesNotExistExceptionSuspectedFileSizeExceptionFailedToCheckpointExceptionBlockInfoExceptionorg.apache.thrift.TExceptionpublic boolean asyncCheckpoint(int fileId)
throws TachyonException,
org.apache.thrift.TException
asyncCheckpoint in interface WorkerService.IfaceTachyonExceptionorg.apache.thrift.TExceptionpublic void send_asyncCheckpoint(int fileId)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic boolean recv_asyncCheckpoint()
throws TachyonException,
org.apache.thrift.TException
TachyonExceptionorg.apache.thrift.TExceptionpublic void cacheBlock(long userId,
long blockId)
throws FileDoesNotExistException,
SuspectedFileSizeException,
BlockInfoException,
org.apache.thrift.TException
cacheBlock in interface WorkerService.IfaceFileDoesNotExistExceptionSuspectedFileSizeExceptionBlockInfoExceptionorg.apache.thrift.TExceptionpublic void send_cacheBlock(long userId,
long blockId)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void recv_cacheBlock()
throws FileDoesNotExistException,
SuspectedFileSizeException,
BlockInfoException,
org.apache.thrift.TException
FileDoesNotExistExceptionSuspectedFileSizeExceptionBlockInfoExceptionorg.apache.thrift.TExceptionpublic String getDataFolder() throws org.apache.thrift.TException
getDataFolder in interface WorkerService.Ifaceorg.apache.thrift.TExceptionpublic void send_getDataFolder()
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic String recv_getDataFolder() throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic String getUserTempFolder(long userId) throws org.apache.thrift.TException
getUserTempFolder in interface WorkerService.Ifaceorg.apache.thrift.TExceptionpublic void send_getUserTempFolder(long userId)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic String recv_getUserTempFolder() throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic String getUserUnderfsTempFolder(long userId) throws org.apache.thrift.TException
getUserUnderfsTempFolder in interface WorkerService.Ifaceorg.apache.thrift.TExceptionpublic void send_getUserUnderfsTempFolder(long userId)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic String recv_getUserUnderfsTempFolder() throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void lockBlock(long blockId,
long userId)
throws org.apache.thrift.TException
lockBlock in interface WorkerService.Ifaceorg.apache.thrift.TExceptionpublic void send_lockBlock(long blockId,
long userId)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void recv_lockBlock()
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void returnSpace(long userId,
long returnedBytes)
throws org.apache.thrift.TException
returnSpace in interface WorkerService.Ifaceorg.apache.thrift.TExceptionpublic void send_returnSpace(long userId,
long returnedBytes)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void recv_returnSpace()
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic boolean requestSpace(long userId,
long requestBytes)
throws org.apache.thrift.TException
requestSpace in interface WorkerService.Ifaceorg.apache.thrift.TExceptionpublic void send_requestSpace(long userId,
long requestBytes)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic boolean recv_requestSpace()
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void unlockBlock(long blockId,
long userId)
throws org.apache.thrift.TException
unlockBlock in interface WorkerService.Ifaceorg.apache.thrift.TExceptionpublic void send_unlockBlock(long blockId,
long userId)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void recv_unlockBlock()
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void userHeartbeat(long userId)
throws org.apache.thrift.TException
userHeartbeat in interface WorkerService.Ifaceorg.apache.thrift.TExceptionpublic void send_userHeartbeat(long userId)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void recv_userHeartbeat()
throws org.apache.thrift.TException
org.apache.thrift.TExceptionCopyright © 2014. All rights reserved.