public class WorkerClient extends Object
| Constructor and Description |
|---|
WorkerClient(InetSocketAddress address,
long userId) |
| Modifier and Type | Method and Description |
|---|---|
void |
accessBlock(long blockId) |
void |
addCheckpoint(long userId,
int fileId) |
boolean |
asyncCheckpoint(int fid) |
void |
cacheBlock(long userId,
long blockId) |
void |
close() |
String |
getDataFolder() |
String |
getUserTempFolder(long userId) |
String |
getUserUnderfsTempFolder(long userId) |
boolean |
isConnected() |
void |
lockBlock(long blockId,
long userId) |
boolean |
open() |
boolean |
requestSpace(long userId,
long requestBytes) |
void |
returnSpace(long userId,
long returnSpaceBytes) |
void |
unlockBlock(long blockId,
long userId) |
void |
userHeartbeat(long userId) |
public WorkerClient(InetSocketAddress address, long userId)
public void accessBlock(long blockId)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void addCheckpoint(long userId,
int fileId)
throws IOException,
org.apache.thrift.TException
IOExceptionorg.apache.thrift.TExceptionpublic void cacheBlock(long userId,
long blockId)
throws IOException,
org.apache.thrift.TException
IOExceptionorg.apache.thrift.TExceptionpublic void close()
public String getUserTempFolder(long userId) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic String getUserUnderfsTempFolder(long userId) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic String getDataFolder() throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic boolean isConnected()
public void lockBlock(long blockId,
long userId)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic boolean open()
public boolean requestSpace(long userId,
long requestBytes)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void returnSpace(long userId,
long returnSpaceBytes)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void unlockBlock(long blockId,
long userId)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void userHeartbeat(long userId)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic boolean asyncCheckpoint(int fid)
throws TachyonException,
org.apache.thrift.TException
TachyonExceptionorg.apache.thrift.TExceptionCopyright © 2014. All rights reserved.