alluxio.thrift

Class FileSystemMasterWorkerService.Client

java.lang.Object

org.apache.thrift.TServiceClient

alluxio.thrift.AlluxioService.Client

alluxio.thrift.FileSystemMasterWorkerService.Client

All Implemented Interfaces:

AlluxioService.Iface, FileSystemMasterWorkerService.Iface

Enclosing class:

FileSystemMasterWorkerService

public static class FileSystemMasterWorkerService.Client
extends AlluxioService.Client
implements FileSystemMasterWorkerService.Iface

Nested Class Summary

Nested Classes

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

Field Summary

Fields inherited from class org.apache.thrift.TServiceClient

iprot_, oprot_, seqid_

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
FileSystemHeartbeatTResponse	fileSystemHeartbeat(long workerId, List<Long> persistedFiles, FileSystemHeartbeatTOptions options) Periodic file system worker heartbeat.
GetFileInfoTResponse	getFileInfo(long fileId, GetFileInfoTOptions options)
GetPinnedFileIdsTResponse	getPinnedFileIds(GetPinnedFileIdsTOptions options) Returns the set of pinned file ids.
GetUfsInfoTResponse	getUfsInfo(long mountId, GetUfsInfoTOptions options) Returns the UFS information for the given mount point identified by its id.
FileSystemHeartbeatTResponse	recv_fileSystemHeartbeat()
GetFileInfoTResponse	recv_getFileInfo()
GetPinnedFileIdsTResponse	recv_getPinnedFileIds()
GetUfsInfoTResponse	recv_getUfsInfo()
void	send_fileSystemHeartbeat(long workerId, List<Long> persistedFiles, FileSystemHeartbeatTOptions options)
void	send_getFileInfo(long fileId, GetFileInfoTOptions options)
void	send_getPinnedFileIds(GetPinnedFileIdsTOptions options)
void	send_getUfsInfo(long mountId, GetUfsInfoTOptions options)

Methods inherited from class alluxio.thrift.AlluxioService.Client

getServiceVersion, recv_getServiceVersion, send_getServiceVersion

Methods inherited from class org.apache.thrift.TServiceClient

getInputProtocol, getOutputProtocol, receiveBase, sendBase, sendBaseOneway

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.thrift.AlluxioService.Iface

getServiceVersion

Constructor Detail

Client

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

Client

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

Method Detail

fileSystemHeartbeat

public FileSystemHeartbeatTResponse fileSystemHeartbeat(long workerId,
                                                        List<Long> persistedFiles,
                                                        FileSystemHeartbeatTOptions options)
                                                 throws AlluxioTException,
                                                        org.apache.thrift.TException

Description copied from interface: FileSystemMasterWorkerService.Iface

Periodic file system worker heartbeat. Returns the command for persisting the blocks of a file.

Specified by:

fileSystemHeartbeat in interface FileSystemMasterWorkerService.Iface

Parameters:

workerId - the id of the worker

persistedFiles - the list of persisted files

options - the method options

Throws:

AlluxioTException

org.apache.thrift.TException

send_fileSystemHeartbeat

public void send_fileSystemHeartbeat(long workerId,
                                     List<Long> persistedFiles,
                                     FileSystemHeartbeatTOptions options)
                              throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_fileSystemHeartbeat

public FileSystemHeartbeatTResponse recv_fileSystemHeartbeat()
                                                      throws AlluxioTException,
                                                             org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException

getFileInfo

public GetFileInfoTResponse getFileInfo(long fileId,
                                        GetFileInfoTOptions options)
                                 throws AlluxioTException,
                                        org.apache.thrift.TException

Specified by:

getFileInfo in interface FileSystemMasterWorkerService.Iface

Throws:

AlluxioTException

org.apache.thrift.TException

send_getFileInfo

public void send_getFileInfo(long fileId,
                             GetFileInfoTOptions options)
                      throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getFileInfo

public GetFileInfoTResponse recv_getFileInfo()
                                      throws AlluxioTException,
                                             org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException

getPinnedFileIds

public GetPinnedFileIdsTResponse getPinnedFileIds(GetPinnedFileIdsTOptions options)
                                           throws AlluxioTException,
                                                  org.apache.thrift.TException

Description copied from interface: FileSystemMasterWorkerService.Iface

Returns the set of pinned file ids.

Specified by:

getPinnedFileIds in interface FileSystemMasterWorkerService.Iface

Parameters:

options - the method options

Throws:

AlluxioTException

org.apache.thrift.TException

send_getPinnedFileIds

public void send_getPinnedFileIds(GetPinnedFileIdsTOptions options)
                           throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getPinnedFileIds

public GetPinnedFileIdsTResponse recv_getPinnedFileIds()
                                                throws AlluxioTException,
                                                       org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException

getUfsInfo

public GetUfsInfoTResponse getUfsInfo(long mountId,
                                      GetUfsInfoTOptions options)
                               throws AlluxioTException,
                                      org.apache.thrift.TException

Description copied from interface: FileSystemMasterWorkerService.Iface

Returns the UFS information for the given mount point identified by its id.

Specified by:

getUfsInfo in interface FileSystemMasterWorkerService.Iface

Parameters:

mountId - the id of the ufs

options - the method options

Throws:

AlluxioTException

org.apache.thrift.TException

send_getUfsInfo

public void send_getUfsInfo(long mountId,
                            GetUfsInfoTOptions options)
                     throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getUfsInfo

public GetUfsInfoTResponse recv_getUfsInfo()
                                    throws AlluxioTException,
                                           org.apache.thrift.TException

Throws:

AlluxioTException

org.apache.thrift.TException