tachyon.thrift

Class WorkerService.Client

java.lang.Object

org.apache.thrift.TServiceClient

tachyon.thrift.WorkerService.Client

All Implemented Interfaces:

WorkerService.Iface

Enclosing class:

WorkerService

public static class WorkerService.Client
extends org.apache.thrift.TServiceClient
implements WorkerService.Iface

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WorkerService.Client.Factory

Field Summary

Fields inherited from class org.apache.thrift.TServiceClient

iprot_, oprot_, seqid_

Constructor Summary

Constructors

Constructor and Description
WorkerService.Client(org.apache.thrift.protocol.TProtocol prot)
WorkerService.Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot)

Method Summary

Methods

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.
void	recv_accessBlock()
void	recv_addCheckpoint()
boolean	recv_asyncCheckpoint()
void	recv_cacheBlock()
void	recv_cancelBlock()
String	recv_getUserUfsTempFolder()
String	recv_lockBlock()
boolean	recv_promoteBlock()
String	recv_requestBlockLocation()
boolean	recv_requestSpace()
boolean	recv_unlockBlock()
void	recv_userHeartbeat()
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.
void	send_accessBlock(long blockId)
void	send_addCheckpoint(long userId, int fileId)
void	send_asyncCheckpoint(int fileId)
void	send_cacheBlock(long userId, long blockId)
void	send_cancelBlock(long userId, long blockId)
void	send_getUserUfsTempFolder(long userId)
void	send_lockBlock(long blockId, long userId)
void	send_promoteBlock(long blockId)
void	send_requestBlockLocation(long userId, long blockId, long initialBytes)
void	send_requestSpace(long userId, long blockId, long requestBytes)
void	send_unlockBlock(long blockId, long userId)
void	send_userHeartbeat(long userId)
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.

Methods inherited from class org.apache.thrift.TServiceClient

getInputProtocol, getOutputProtocol, receiveBase, sendBase

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WorkerService.Client

public WorkerService.Client(org.apache.thrift.protocol.TProtocol prot)

WorkerService.Client

public WorkerService.Client(org.apache.thrift.protocol.TProtocol iprot,
                    org.apache.thrift.protocol.TProtocol oprot)

Method Detail

accessBlock

public void accessBlock(long blockId)
                 throws org.apache.thrift.TException

Specified by:

accessBlock in interface WorkerService.Iface

Throws:

org.apache.thrift.TException

send_accessBlock

public void send_accessBlock(long blockId)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_accessBlock

public void recv_accessBlock()
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

addCheckpoint

public void addCheckpoint(long userId,
                 int fileId)
                   throws FileDoesNotExistException,
                          SuspectedFileSizeException,
                          FailedToCheckpointException,
                          BlockInfoException,
                          org.apache.thrift.TException

Specified by:

addCheckpoint in interface WorkerService.Iface

Throws:

FileDoesNotExistException

SuspectedFileSizeException

FailedToCheckpointException

BlockInfoException

org.apache.thrift.TException

send_addCheckpoint

public void send_addCheckpoint(long userId,
                      int fileId)
                        throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_addCheckpoint

public void recv_addCheckpoint()
                        throws FileDoesNotExistException,
                               SuspectedFileSizeException,
                               FailedToCheckpointException,
                               BlockInfoException,
                               org.apache.thrift.TException

Throws:

FileDoesNotExistException

SuspectedFileSizeException

FailedToCheckpointException

BlockInfoException

org.apache.thrift.TException

asyncCheckpoint

public boolean asyncCheckpoint(int fileId)
                        throws TachyonException,
                               org.apache.thrift.TException

Specified by:

asyncCheckpoint in interface WorkerService.Iface

Throws:

TachyonException

org.apache.thrift.TException

send_asyncCheckpoint

public void send_asyncCheckpoint(int fileId)
                          throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_asyncCheckpoint

public boolean recv_asyncCheckpoint()
                             throws TachyonException,
                                    org.apache.thrift.TException

Throws:

TachyonException

org.apache.thrift.TException

cacheBlock

public void cacheBlock(long userId,
              long blockId)
                throws FileDoesNotExistException,
                       SuspectedFileSizeException,
                       BlockInfoException,
                       org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

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. then update the block information to master.

Specified by:

cacheBlock in interface WorkerService.Iface

Throws:

FileDoesNotExistException

SuspectedFileSizeException

BlockInfoException

org.apache.thrift.TException

send_cacheBlock

public void send_cacheBlock(long userId,
                   long blockId)
                     throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_cacheBlock

public void recv_cacheBlock()
                     throws FileDoesNotExistException,
                            SuspectedFileSizeException,
                            BlockInfoException,
                            org.apache.thrift.TException

Throws:

FileDoesNotExistException

SuspectedFileSizeException

BlockInfoException

org.apache.thrift.TException

cancelBlock

public void cancelBlock(long userId,
               long blockId)
                 throws org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

Used to cancel a block which is being written. worker will delete the temporary block file and the location and space information related, then reclaim space allocated to the block.

Specified by:

cancelBlock in interface WorkerService.Iface

Throws:

org.apache.thrift.TException

send_cancelBlock

public void send_cancelBlock(long userId,
                    long blockId)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_cancelBlock

public void recv_cancelBlock()
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

getUserUfsTempFolder

public String getUserUfsTempFolder(long userId)
                            throws org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

Used to get user's temporary folder on under file system, and the path of the user's temporary folder will be returned.

Specified by:

getUserUfsTempFolder in interface WorkerService.Iface

Throws:

org.apache.thrift.TException

send_getUserUfsTempFolder

public void send_getUserUfsTempFolder(long userId)
                               throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getUserUfsTempFolder

public String recv_getUserUfsTempFolder()
                                 throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

lockBlock

public String lockBlock(long blockId,
               long userId)
                 throws FileDoesNotExistException,
                        org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

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.

Specified by:

lockBlock in interface WorkerService.Iface

Throws:

FileDoesNotExistException

org.apache.thrift.TException

send_lockBlock

public void send_lockBlock(long blockId,
                  long userId)
                    throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_lockBlock

public String recv_lockBlock()
                      throws FileDoesNotExistException,
                             org.apache.thrift.TException

Throws:

FileDoesNotExistException

org.apache.thrift.TException

promoteBlock

public boolean promoteBlock(long blockId)
                     throws org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

Used to promote block on under storage layer to top storage layer when there are more than one storage layers in Tachyon's space. return true if the block is successfully promoted, false otherwise.

Specified by:

promoteBlock in interface WorkerService.Iface

Throws:

org.apache.thrift.TException

send_promoteBlock

public void send_promoteBlock(long blockId)
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_promoteBlock

public boolean recv_promoteBlock()
                          throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

requestBlockLocation

public String requestBlockLocation(long userId,
                          long blockId,
                          long initialBytes)
                            throws OutOfSpaceException,
                                   FileAlreadyExistException,
                                   org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

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. if there is no enough space on Tachyon storage OutOfSpaceException will be thrown, if the file is already being written by the user, FileAlreadyExistException will be thrown.

Specified by:

requestBlockLocation in interface WorkerService.Iface

Throws:

OutOfSpaceException

FileAlreadyExistException

org.apache.thrift.TException

send_requestBlockLocation

public void send_requestBlockLocation(long userId,
                             long blockId,
                             long initialBytes)
                               throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_requestBlockLocation

public String recv_requestBlockLocation()
                                 throws OutOfSpaceException,
                                        FileAlreadyExistException,
                                        org.apache.thrift.TException

Throws:

OutOfSpaceException

FileAlreadyExistException

org.apache.thrift.TException

requestSpace

public boolean requestSpace(long userId,
                   long blockId,
                   long requestBytes)
                     throws FileDoesNotExistException,
                            org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

Used to request space for some block file. return true if the worker successfully allocates space for the block on block’s location, false if there is no enough space, if there is no information of the block on worker, FileDoesNotExistException will be thrown.

Specified by:

requestSpace in interface WorkerService.Iface

Throws:

FileDoesNotExistException

org.apache.thrift.TException

send_requestSpace

public void send_requestSpace(long userId,
                     long blockId,
                     long requestBytes)
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_requestSpace

public boolean recv_requestSpace()
                          throws FileDoesNotExistException,
                                 org.apache.thrift.TException

Throws:

FileDoesNotExistException

org.apache.thrift.TException

unlockBlock

public boolean unlockBlock(long blockId,
                  long userId)
                    throws org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

Used to unlock a block after the block is accessed, if the block is to be removed, delete the block file. return true if successfully unlock the block, return false if the block is not found or failed to delete the block.

Specified by:

unlockBlock in interface WorkerService.Iface

Throws:

org.apache.thrift.TException

send_unlockBlock

public void send_unlockBlock(long blockId,
                    long userId)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_unlockBlock

public boolean recv_unlockBlock()
                         throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

userHeartbeat

public void userHeartbeat(long userId)
                   throws org.apache.thrift.TException

Description copied from interface: WorkerService.Iface

Local user send heartbeat to local worker to keep its temporary folder.

Specified by:

userHeartbeat in interface WorkerService.Iface

Throws:

org.apache.thrift.TException

send_userHeartbeat

public void send_userHeartbeat(long userId)
                        throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_userHeartbeat

public void recv_userHeartbeat()
                        throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException