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.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
cacheBlock
in interface WorkerService.Iface
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 String getUserTempFolder(long userId) throws org.apache.thrift.TException
getUserTempFolder
in interface WorkerService.Iface
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 lockBlock(long blockId, long userId) throws org.apache.thrift.TException
lockBlock
in interface WorkerService.Iface
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 boolean requestSpace(long userId, long requestBytes) throws org.apache.thrift.TException
requestSpace
in interface WorkerService.Iface
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 userHeartbeat(long userId) throws org.apache.thrift.TException
userHeartbeat
in interface WorkerService.Iface
org.apache.thrift.TException
Copyright © 2014. All rights reserved.