alluxio.master.file

Class FileSystemMasterWorkerServiceHandler

java.lang.Object

alluxio.master.file.FileSystemMasterWorkerServiceHandler

All Implemented Interfaces:

AlluxioService.Iface, FileSystemMasterWorkerService.Iface

@NotThreadSafe
public final class FileSystemMasterWorkerServiceHandler
extends Object
implements FileSystemMasterWorkerService.Iface

This class is a Thrift handler for file system master RPCs invoked by an Alluxio worker.

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.
GetServiceVersionTResponse	getServiceVersion(GetServiceVersionTOptions options) Returns the version of the master service.
GetUfsInfoTResponse	getUfsInfo(long mountId, GetUfsInfoTOptions options) Returns the UFS information for the given mount point identified by its id.

Methods inherited from class java.lang.Object

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

Method Detail

getServiceVersion

public GetServiceVersionTResponse getServiceVersion(GetServiceVersionTOptions options)

Description copied from interface: AlluxioService.Iface

Returns the version of the master service. NOTE: The version should be updated every time a backwards incompatible API change occurs.

Specified by:

getServiceVersion in interface AlluxioService.Iface

Parameters:

options - the method options

fileSystemHeartbeat

public FileSystemHeartbeatTResponse fileSystemHeartbeat(long workerId,
                                                        List<Long> persistedFiles,
                                                        FileSystemHeartbeatTOptions options)
                                                 throws AlluxioTException

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

getFileInfo

public GetFileInfoTResponse getFileInfo(long fileId,
                                        GetFileInfoTOptions options)
                                 throws AlluxioTException

Specified by:

getFileInfo in interface FileSystemMasterWorkerService.Iface

Throws:

AlluxioTException

getPinnedFileIds

public GetPinnedFileIdsTResponse getPinnedFileIds(GetPinnedFileIdsTOptions options)
                                           throws AlluxioTException

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

getUfsInfo

public GetUfsInfoTResponse getUfsInfo(long mountId,
                                      GetUfsInfoTOptions options)
                               throws AlluxioTException

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