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.TException
public void addCheckpoint(long userId, int fileId) throws IOException, org.apache.thrift.TException
IOException
org.apache.thrift.TException
public void cacheBlock(long userId, long blockId) throws IOException, org.apache.thrift.TException
IOException
org.apache.thrift.TException
public void close()
public String getUserTempFolder(long userId) throws org.apache.thrift.TException
org.apache.thrift.TException
public String getUserUnderfsTempFolder(long userId) throws org.apache.thrift.TException
org.apache.thrift.TException
public String getDataFolder() throws org.apache.thrift.TException
org.apache.thrift.TException
public boolean isConnected()
public void lockBlock(long blockId, long userId) throws org.apache.thrift.TException
org.apache.thrift.TException
public boolean open()
public boolean requestSpace(long userId, long requestBytes) throws org.apache.thrift.TException
org.apache.thrift.TException
public void returnSpace(long userId, long returnSpaceBytes) throws org.apache.thrift.TException
org.apache.thrift.TException
public void unlockBlock(long blockId, long userId) throws org.apache.thrift.TException
org.apache.thrift.TException
public void userHeartbeat(long userId) throws org.apache.thrift.TException
org.apache.thrift.TException
public boolean asyncCheckpoint(int fid) throws TachyonException, org.apache.thrift.TException
TachyonException
org.apache.thrift.TException
Copyright © 2014. All rights reserved.