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.Iface
org.apache.thrift.TException
public void send_accessBlock(long blockId) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_accessBlock() throws org.apache.thrift.TException
org.apache.thrift.TException
public void addCheckpoint(long userId, int fileId) throws FileDoesNotExistException, SuspectedFileSizeException, FailedToCheckpointException, BlockInfoException, org.apache.thrift.TException
addCheckpoint
in interface WorkerService.Iface
FileDoesNotExistException
SuspectedFileSizeException
FailedToCheckpointException
BlockInfoException
org.apache.thrift.TException
public void send_addCheckpoint(long userId, int fileId) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_addCheckpoint() throws FileDoesNotExistException, SuspectedFileSizeException, FailedToCheckpointException, BlockInfoException, org.apache.thrift.TException
FileDoesNotExistException
SuspectedFileSizeException
FailedToCheckpointException
BlockInfoException
org.apache.thrift.TException
public boolean asyncCheckpoint(int fileId) throws TachyonException, org.apache.thrift.TException
asyncCheckpoint
in interface WorkerService.Iface
TachyonException
org.apache.thrift.TException
public void send_asyncCheckpoint(int fileId) throws org.apache.thrift.TException
org.apache.thrift.TException
public boolean recv_asyncCheckpoint() throws TachyonException, org.apache.thrift.TException
TachyonException
org.apache.thrift.TException
public void cacheBlock(long userId, long blockId) throws FileDoesNotExistException, SuspectedFileSizeException, BlockInfoException, org.apache.thrift.TException
cacheBlock
in interface WorkerService.Iface
FileDoesNotExistException
SuspectedFileSizeException
BlockInfoException
org.apache.thrift.TException
public void send_cacheBlock(long userId, long blockId) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_cacheBlock() throws FileDoesNotExistException, SuspectedFileSizeException, BlockInfoException, org.apache.thrift.TException
FileDoesNotExistException
SuspectedFileSizeException
BlockInfoException
org.apache.thrift.TException
public String getDataFolder() throws org.apache.thrift.TException
getDataFolder
in interface WorkerService.Iface
org.apache.thrift.TException
public void send_getDataFolder() throws org.apache.thrift.TException
org.apache.thrift.TException
public String recv_getDataFolder() throws org.apache.thrift.TException
org.apache.thrift.TException
public String getUserTempFolder(long userId) throws org.apache.thrift.TException
getUserTempFolder
in interface WorkerService.Iface
org.apache.thrift.TException
public void send_getUserTempFolder(long userId) throws org.apache.thrift.TException
org.apache.thrift.TException
public String recv_getUserTempFolder() throws org.apache.thrift.TException
org.apache.thrift.TException
public String getUserUnderfsTempFolder(long userId) throws org.apache.thrift.TException
getUserUnderfsTempFolder
in interface WorkerService.Iface
org.apache.thrift.TException
public void send_getUserUnderfsTempFolder(long userId) throws org.apache.thrift.TException
org.apache.thrift.TException
public String recv_getUserUnderfsTempFolder() throws org.apache.thrift.TException
org.apache.thrift.TException
public void lockBlock(long blockId, long userId) throws org.apache.thrift.TException
lockBlock
in interface WorkerService.Iface
org.apache.thrift.TException
public void send_lockBlock(long blockId, long userId) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_lockBlock() throws org.apache.thrift.TException
org.apache.thrift.TException
public void returnSpace(long userId, long returnedBytes) throws org.apache.thrift.TException
returnSpace
in interface WorkerService.Iface
org.apache.thrift.TException
public void send_returnSpace(long userId, long returnedBytes) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_returnSpace() throws org.apache.thrift.TException
org.apache.thrift.TException
public boolean requestSpace(long userId, long requestBytes) throws org.apache.thrift.TException
requestSpace
in interface WorkerService.Iface
org.apache.thrift.TException
public void send_requestSpace(long userId, long requestBytes) throws org.apache.thrift.TException
org.apache.thrift.TException
public boolean recv_requestSpace() throws org.apache.thrift.TException
org.apache.thrift.TException
public void unlockBlock(long blockId, long userId) throws org.apache.thrift.TException
unlockBlock
in interface WorkerService.Iface
org.apache.thrift.TException
public void send_unlockBlock(long blockId, long userId) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_unlockBlock() throws org.apache.thrift.TException
org.apache.thrift.TException
public void userHeartbeat(long userId) throws org.apache.thrift.TException
userHeartbeat
in interface WorkerService.Iface
org.apache.thrift.TException
public void send_userHeartbeat(long userId) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_userHeartbeat() throws org.apache.thrift.TException
org.apache.thrift.TException
Copyright © 2014. All rights reserved.