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) |
String |
getDataFolder() |
String |
getUserTempFolder(long userId) |
String |
getUserUnderfsTempFolder(long userId) |
void |
lockBlock(long blockId,
long userId) |
boolean |
requestSpace(long userId,
long requestBytes) |
void |
returnSpace(long userId,
long returnedBytes) |
void |
unlockBlock(long blockId,
long userId) |
void |
userHeartbeat(long userId) |
public WorkerServiceHandler(WorkerStorage workerStorage)
public void accessBlock(long blockId)
throws org.apache.thrift.TException
accessBlock in interface WorkerService.Ifaceorg.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 boolean asyncCheckpoint(int fileId)
throws TachyonException,
org.apache.thrift.TException
asyncCheckpoint in interface WorkerService.IfaceTachyonExceptionorg.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 String getDataFolder() throws org.apache.thrift.TException
getDataFolder in interface WorkerService.Ifaceorg.apache.thrift.TExceptionpublic String getUserTempFolder(long userId) throws org.apache.thrift.TException
getUserTempFolder in interface WorkerService.Ifaceorg.apache.thrift.TExceptionpublic String getUserUnderfsTempFolder(long userId) throws org.apache.thrift.TException
getUserUnderfsTempFolder in interface WorkerService.Ifaceorg.apache.thrift.TExceptionpublic void lockBlock(long blockId,
long userId)
throws org.apache.thrift.TException
lockBlock in interface WorkerService.Ifaceorg.apache.thrift.TExceptionpublic void returnSpace(long userId,
long returnedBytes)
throws org.apache.thrift.TException
returnSpace in interface WorkerService.Ifaceorg.apache.thrift.TExceptionpublic boolean requestSpace(long userId,
long requestBytes)
throws org.apache.thrift.TException
requestSpace in interface WorkerService.Ifaceorg.apache.thrift.TExceptionpublic void unlockBlock(long blockId,
long userId)
throws org.apache.thrift.TException
unlockBlock in interface WorkerService.Ifaceorg.apache.thrift.TExceptionpublic void userHeartbeat(long userId)
throws org.apache.thrift.TException
userHeartbeat in interface WorkerService.Ifaceorg.apache.thrift.TExceptionCopyright © 2014. All rights reserved.