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)
Used to cache a block into Tachyon space, worker will move the temporary block file from user
folder to data folder, and update the space usage information related.
|
void |
cancelBlock(long userId,
long blockId)
Used to cancel a block which is being written.
|
String |
getUserUfsTempFolder(long userId)
Used to get user's temporary folder on under file system, and the path of the user's temporary
folder will be returned.
|
String |
lockBlock(long blockId,
long userId)
Lock the file in Tachyon's space while the user is reading it, and the path of the block file
locked will be returned, if the block file is not found, FileDoesNotExistException will be
thrown.
|
boolean |
promoteBlock(long blockId)
Used to promote block on under storage layer to top storage layer when there are more than one
storage layers in Tachyon's space.
|
void |
recv_accessBlock() |
void |
recv_addCheckpoint() |
boolean |
recv_asyncCheckpoint() |
void |
recv_cacheBlock() |
void |
recv_cancelBlock() |
String |
recv_getUserUfsTempFolder() |
String |
recv_lockBlock() |
boolean |
recv_promoteBlock() |
String |
recv_requestBlockLocation() |
boolean |
recv_requestSpace() |
boolean |
recv_unlockBlock() |
void |
recv_userHeartbeat() |
String |
requestBlockLocation(long userId,
long blockId,
long initialBytes)
Used to allocate location and space for a new coming block, worker will choose the appropriate
storage directory which fits the initial block size by some allocation strategy, and the
temporary file path of the block file will be returned.
|
boolean |
requestSpace(long userId,
long blockId,
long requestBytes)
Used to request space for some block file.
|
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_cancelBlock(long userId,
long blockId) |
void |
send_getUserUfsTempFolder(long userId) |
void |
send_lockBlock(long blockId,
long userId) |
void |
send_promoteBlock(long blockId) |
void |
send_requestBlockLocation(long userId,
long blockId,
long initialBytes) |
void |
send_requestSpace(long userId,
long blockId,
long requestBytes) |
void |
send_unlockBlock(long blockId,
long userId) |
void |
send_userHeartbeat(long userId) |
boolean |
unlockBlock(long blockId,
long userId)
Used to unlock a block after the block is accessed, if the block is to be removed, delete the
block file.
|
void |
userHeartbeat(long userId)
Local user send heartbeat to local worker to keep its temporary folder.
|
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
WorkerService.Iface
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 void cancelBlock(long userId, long blockId) throws org.apache.thrift.TException
WorkerService.Iface
cancelBlock
in interface WorkerService.Iface
org.apache.thrift.TException
public void send_cancelBlock(long userId, long blockId) throws org.apache.thrift.TException
org.apache.thrift.TException
public void recv_cancelBlock() throws org.apache.thrift.TException
org.apache.thrift.TException
public String getUserUfsTempFolder(long userId) throws org.apache.thrift.TException
WorkerService.Iface
getUserUfsTempFolder
in interface WorkerService.Iface
org.apache.thrift.TException
public void send_getUserUfsTempFolder(long userId) throws org.apache.thrift.TException
org.apache.thrift.TException
public String recv_getUserUfsTempFolder() throws org.apache.thrift.TException
org.apache.thrift.TException
public String lockBlock(long blockId, long userId) throws FileDoesNotExistException, org.apache.thrift.TException
WorkerService.Iface
lockBlock
in interface WorkerService.Iface
FileDoesNotExistException
org.apache.thrift.TException
public void send_lockBlock(long blockId, long userId) throws org.apache.thrift.TException
org.apache.thrift.TException
public String recv_lockBlock() throws FileDoesNotExistException, org.apache.thrift.TException
FileDoesNotExistException
org.apache.thrift.TException
public boolean promoteBlock(long blockId) throws org.apache.thrift.TException
WorkerService.Iface
promoteBlock
in interface WorkerService.Iface
org.apache.thrift.TException
public void send_promoteBlock(long blockId) throws org.apache.thrift.TException
org.apache.thrift.TException
public boolean recv_promoteBlock() throws org.apache.thrift.TException
org.apache.thrift.TException
public String requestBlockLocation(long userId, long blockId, long initialBytes) throws OutOfSpaceException, FileAlreadyExistException, org.apache.thrift.TException
WorkerService.Iface
requestBlockLocation
in interface WorkerService.Iface
OutOfSpaceException
FileAlreadyExistException
org.apache.thrift.TException
public void send_requestBlockLocation(long userId, long blockId, long initialBytes) throws org.apache.thrift.TException
org.apache.thrift.TException
public String recv_requestBlockLocation() throws OutOfSpaceException, FileAlreadyExistException, org.apache.thrift.TException
OutOfSpaceException
FileAlreadyExistException
org.apache.thrift.TException
public boolean requestSpace(long userId, long blockId, long requestBytes) throws FileDoesNotExistException, org.apache.thrift.TException
WorkerService.Iface
requestSpace
in interface WorkerService.Iface
FileDoesNotExistException
org.apache.thrift.TException
public void send_requestSpace(long userId, long blockId, long requestBytes) throws org.apache.thrift.TException
org.apache.thrift.TException
public boolean recv_requestSpace() throws FileDoesNotExistException, org.apache.thrift.TException
FileDoesNotExistException
org.apache.thrift.TException
public boolean unlockBlock(long blockId, long userId) throws org.apache.thrift.TException
WorkerService.Iface
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 boolean recv_unlockBlock() throws org.apache.thrift.TException
org.apache.thrift.TException
public void userHeartbeat(long userId) throws org.apache.thrift.TException
WorkerService.Iface
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 © 2015. All Rights Reserved.