public class WorkerServiceHandler extends Object implements WorkerService.Iface
WorkerServiceHandler
handles all the RPC calls to the worker.Constructor and Description |
---|
WorkerServiceHandler(WorkerStorage workerStorage) |
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.
|
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.
|
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 WorkerServiceHandler(WorkerStorage workerStorage)
public void accessBlock(long blockId) throws org.apache.thrift.TException
accessBlock
in interface WorkerService.Iface
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 boolean asyncCheckpoint(int fileId) throws TachyonException, org.apache.thrift.TException
asyncCheckpoint
in interface WorkerService.Iface
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 cancelBlock(long userId, long blockId) throws org.apache.thrift.TException
WorkerService.Iface
cancelBlock
in interface WorkerService.Iface
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 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 boolean promoteBlock(long blockId) throws org.apache.thrift.TException
WorkerService.Iface
promoteBlock
in interface WorkerService.Iface
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 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 boolean unlockBlock(long blockId, long userId) throws org.apache.thrift.TException
WorkerService.Iface
unlockBlock
in interface WorkerService.Iface
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
Copyright © 2015. All Rights Reserved.