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) |
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() |
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_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 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 © 2013. All rights reserved.