alluxio.master.file

Class FileSystemMasterWorkerServiceHandler

java.lang.Object

alluxio.grpc.FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase

alluxio.master.file.FileSystemMasterWorkerServiceHandler

All Implemented Interfaces:

FileSystemMasterWorkerServiceGrpc.AsyncService, io.grpc.BindableService

public final class FileSystemMasterWorkerServiceHandler
extends FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase

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

Constructor Summary

Constructors

Constructor and Description
FileSystemMasterWorkerServiceHandler(FileSystemMaster fileSystemMaster) Creates a new instance of FileSystemMasterWorkerServiceHandler.

Method Summary

Modifier and Type	Method and Description
void	fileSystemHeartbeat(FileSystemHeartbeatPRequest request, io.grpc.stub.StreamObserver<FileSystemHeartbeatPResponse> responseObserver) Periodic file system worker heartbeat.
void	getFileInfo(GetFileInfoPRequest request, io.grpc.stub.StreamObserver<GetFileInfoPResponse> responseObserver) Returns the file information for a file or directory identified by the given file id.
void	getMountId(GetMountIdPRequest request, io.grpc.stub.StreamObserver<GetMountIdPResponse> responseObserver) Reverse resolve a ufs path and get mount id.
void	getPinnedFileIds(GetPinnedFileIdsPRequest request, io.grpc.stub.StreamObserver<GetPinnedFileIdsPResponse> responseObserver) Returns the set of pinned file ids.
void	getUfsInfo(GetUfsInfoPRequest request, io.grpc.stub.StreamObserver<GetUfsInfoPResponse> responseObserver) Returns the UFS information for the given mount point identified by its id.

Methods inherited from class alluxio.grpc.FileSystemMasterWorkerServiceGrpc.FileSystemMasterWorkerServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

FileSystemMasterWorkerServiceHandler

public FileSystemMasterWorkerServiceHandler(FileSystemMaster fileSystemMaster)

Creates a new instance of FileSystemMasterWorkerServiceHandler.

Parameters:

fileSystemMaster - the FileSystemMaster the handler uses internally

Method Detail

fileSystemHeartbeat

public void fileSystemHeartbeat(FileSystemHeartbeatPRequest request,
                                io.grpc.stub.StreamObserver<FileSystemHeartbeatPResponse> responseObserver)

Description copied from interface: FileSystemMasterWorkerServiceGrpc.AsyncService

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

getFileInfo

public void getFileInfo(GetFileInfoPRequest request,
                        io.grpc.stub.StreamObserver<GetFileInfoPResponse> responseObserver)

Description copied from interface: FileSystemMasterWorkerServiceGrpc.AsyncService

 Returns the file information for a file or directory identified by the given file id.
 

getPinnedFileIds

public void getPinnedFileIds(GetPinnedFileIdsPRequest request,
                             io.grpc.stub.StreamObserver<GetPinnedFileIdsPResponse> responseObserver)

Description copied from interface: FileSystemMasterWorkerServiceGrpc.AsyncService

 Returns the set of pinned file ids.
 

getUfsInfo

public void getUfsInfo(GetUfsInfoPRequest request,
                       io.grpc.stub.StreamObserver<GetUfsInfoPResponse> responseObserver)

Description copied from interface: FileSystemMasterWorkerServiceGrpc.AsyncService

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

getMountId

public void getMountId(GetMountIdPRequest request,
                       io.grpc.stub.StreamObserver<GetMountIdPResponse> responseObserver)

Description copied from interface: FileSystemMasterWorkerServiceGrpc.AsyncService

 Reverse resolve a ufs path and get mount id.