alluxio.master.file

Class FileSystemMasterClientServiceHandler

java.lang.Object

alluxio.grpc.FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

alluxio.master.file.FileSystemMasterClientServiceHandler

All Implemented Interfaces:

io.grpc.BindableService

public final class FileSystemMasterClientServiceHandler
extends FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

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

Constructor Summary

Constructors

Constructor and Description
FileSystemMasterClientServiceHandler(FileSystemMaster fileSystemMaster, Scheduler scheduler) Creates a new instance of FileSystemMasterClientServiceHandler.

Method Summary

Modifier and Type	Method and Description
void	checkAccess(CheckAccessPRequest request, io.grpc.stub.StreamObserver<CheckAccessPResponse> responseObserver) Checks access to path.
void	checkConsistency(CheckConsistencyPRequest request, io.grpc.stub.StreamObserver<CheckConsistencyPResponse> responseObserver) Checks the consistency of the files and directores with the path as the root of the subtree
void	completeFile(CompleteFilePRequest request, io.grpc.stub.StreamObserver<CompleteFilePResponse> responseObserver) Marks a file as completed.
void	createDirectory(CreateDirectoryPRequest request, io.grpc.stub.StreamObserver<CreateDirectoryPResponse> responseObserver) Creates a directory.
void	createFile(CreateFilePRequest request, io.grpc.stub.StreamObserver<CreateFilePResponse> responseObserver) Creates a file.
void	exists(ExistsPRequest request, io.grpc.stub.StreamObserver<ExistsPResponse> responseObserver) Checks the existence of the file or directory.
void	free(FreePRequest request, io.grpc.stub.StreamObserver<FreePResponse> responseObserver) Frees the given file or directory from Alluxio.
void	getFilePath(GetFilePathPRequest request, io.grpc.stub.StreamObserver<GetFilePathPResponse> responseObserver) Returns the file path of a file id
void	getJobProgress(GetJobProgressPRequest request, io.grpc.stub.StreamObserver<GetJobProgressPResponse> responseObserver)
void	getMountTable(GetMountTablePRequest request, io.grpc.stub.StreamObserver<GetMountTablePResponse> responseObserver) Returns a map from each Alluxio path to information of corresponding mount point
void	getNewBlockIdForFile(GetNewBlockIdForFilePRequest request, io.grpc.stub.StreamObserver<GetNewBlockIdForFilePResponse> responseObserver) Generates a new block id for the given file.
void	getStateLockHolders(GetStateLockHoldersPRequest request, io.grpc.stub.StreamObserver<GetStateLockHoldersPResponse> responseObserver)
void	getStatus(GetStatusPRequest request, io.grpc.stub.StreamObserver<GetStatusPResponse> responseObserver) Returns the status of the file or directory.
void	getSyncPathList(GetSyncPathListPRequest request, io.grpc.stub.StreamObserver<GetSyncPathListPResponse> responseObserver) Returns a list of paths that are being actively synced by Alluxio
void	listStatus(ListStatusPRequest request, io.grpc.stub.StreamObserver<ListStatusPResponse> responseObserver) If the path points to a file, the method returns a singleton with its file information.
void	listStatusPartial(ListStatusPartialPRequest request, io.grpc.stub.StreamObserver<ListStatusPartialPResponse> responseObserver) If the path points to a file, the method returns a singleton with its file information.
void	mount(MountPRequest request, io.grpc.stub.StreamObserver<MountPResponse> responseObserver) Creates a new "mount point", mounts the given UFS path in the Alluxio namespace at the given path.
void	needsSync(NeedsSyncRequest request, io.grpc.stub.StreamObserver<NeedsSyncResponse> responseObserver)
void	remove(DeletePRequest request, io.grpc.stub.StreamObserver<DeletePResponse> responseObserver) Deletes a file or a directory and returns whether the remove operation succeeded.
void	rename(RenamePRequest request, io.grpc.stub.StreamObserver<RenamePResponse> responseObserver) Renames a file or a directory.
void	reverseResolve(ReverseResolvePRequest request, io.grpc.stub.StreamObserver<ReverseResolvePResponse> responseObserver) Reverse resolve a ufs path.
void	scheduleAsyncPersistence(ScheduleAsyncPersistencePRequest request, io.grpc.stub.StreamObserver<ScheduleAsyncPersistencePResponse> responseObserver) Schedules async persistence.
void	setAcl(SetAclPRequest request, io.grpc.stub.StreamObserver<SetAclPResponse> responseObserver) Sets ACL for the path.
void	setAttribute(SetAttributePRequest request, io.grpc.stub.StreamObserver<SetAttributePResponse> responseObserver) Sets file or directory attributes.
void	startSync(StartSyncPRequest request, io.grpc.stub.StreamObserver<StartSyncPResponse> responseObserver) Start the active syncing of the directory or file
void	stopJob(StopJobPRequest request, io.grpc.stub.StreamObserver<StopJobPResponse> responseObserver)
void	stopSync(StopSyncPRequest request, io.grpc.stub.StreamObserver<StopSyncPResponse> responseObserver) Start the active syncing of the directory or file
void	submitJob(SubmitJobPRequest request, io.grpc.stub.StreamObserver<SubmitJobPResponse> responseObserver) Load a directory into Alluxio.
void	unmount(UnmountPRequest request, io.grpc.stub.StreamObserver<UnmountPResponse> responseObserver) Deletes an existing "mount point", voiding the Alluxio namespace at the given path.
void	updateMount(UpdateMountPRequest request, io.grpc.stub.StreamObserver<UpdateMountPResponse> responseObserver) Updates an existing "mount point", changing its mount properties
void	updateUfsMode(UpdateUfsModePRequest request, io.grpc.stub.StreamObserver<UpdateUfsModePResponse> responseObserver) Updates the ufs mode for a ufs path under one or more mount points.

Methods inherited from class alluxio.grpc.FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

FileSystemMasterClientServiceHandler

public FileSystemMasterClientServiceHandler(FileSystemMaster fileSystemMaster,
                                            Scheduler scheduler)

Creates a new instance of FileSystemMasterClientServiceHandler.

Parameters:

fileSystemMaster - the FileSystemMaster the handler uses internally

scheduler - the Scheduler

Method Detail

checkAccess

public void checkAccess(CheckAccessPRequest request,
                        io.grpc.stub.StreamObserver<CheckAccessPResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Checks access to path.
 

Overrides:

checkAccess in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

checkConsistency

public void checkConsistency(CheckConsistencyPRequest request,
                             io.grpc.stub.StreamObserver<CheckConsistencyPResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Checks the consistency of the files and directores with the path as the root of the subtree
 

Overrides:

checkConsistency in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

exists

public void exists(ExistsPRequest request,
                   io.grpc.stub.StreamObserver<ExistsPResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Checks the existence of the file or directory.
 

Overrides:

exists in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

completeFile

public void completeFile(CompleteFilePRequest request,
                         io.grpc.stub.StreamObserver<CompleteFilePResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Marks a file as completed.
 

Overrides:

completeFile in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

createDirectory

public void createDirectory(CreateDirectoryPRequest request,
                            io.grpc.stub.StreamObserver<CreateDirectoryPResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Creates a directory.
 

Overrides:

createDirectory in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

createFile

public void createFile(CreateFilePRequest request,
                       io.grpc.stub.StreamObserver<CreateFilePResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Creates a file.
 

Overrides:

createFile in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

free

public void free(FreePRequest request,
                 io.grpc.stub.StreamObserver<FreePResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Frees the given file or directory from Alluxio.
 

Overrides:

free in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

getNewBlockIdForFile

public void getNewBlockIdForFile(GetNewBlockIdForFilePRequest request,
                                 io.grpc.stub.StreamObserver<GetNewBlockIdForFilePResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Generates a new block id for the given file.
 

Overrides:

getNewBlockIdForFile in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

getFilePath

public void getFilePath(GetFilePathPRequest request,
                        io.grpc.stub.StreamObserver<GetFilePathPResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Returns the file path of a file id
 

Overrides:

getFilePath in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

getStatus

public void getStatus(GetStatusPRequest request,
                      io.grpc.stub.StreamObserver<GetStatusPResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Returns the status of the file or directory.
 

Overrides:

getStatus in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

listStatus

public void listStatus(ListStatusPRequest request,
                       io.grpc.stub.StreamObserver<ListStatusPResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 If the path points to a file, the method returns a singleton with its file information.
 If the path points to a directory, the method returns a list with file information for the
 directory contents.
 

Overrides:

listStatus in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

listStatusPartial

public void listStatusPartial(ListStatusPartialPRequest request,
                              io.grpc.stub.StreamObserver<ListStatusPartialPResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 If the path points to a file, the method returns a singleton with its file information.
 If the path points to a directory, the method returns a list with file information for the
 directory contents. This operation takes additional options for partial listing of files.
 

Overrides:

listStatusPartial in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

mount

public void mount(MountPRequest request,
                  io.grpc.stub.StreamObserver<MountPResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Creates a new "mount point", mounts the given UFS path in the Alluxio namespace at the given
 path. The path should not exist and should not be nested under any existing mount point.
 

Overrides:

mount in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

updateMount

public void updateMount(UpdateMountPRequest request,
                        io.grpc.stub.StreamObserver<UpdateMountPResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Updates an existing "mount point", changing its mount properties
 

Overrides:

updateMount in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

getMountTable

public void getMountTable(GetMountTablePRequest request,
                          io.grpc.stub.StreamObserver<GetMountTablePResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Returns a map from each Alluxio path to information of corresponding mount point
 

Overrides:

getMountTable in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

getSyncPathList

public void getSyncPathList(GetSyncPathListPRequest request,
                            io.grpc.stub.StreamObserver<GetSyncPathListPResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Returns a list of paths that are being actively synced by Alluxio
 

Overrides:

getSyncPathList in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

remove

public void remove(DeletePRequest request,
                   io.grpc.stub.StreamObserver<DeletePResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Deletes a file or a directory and returns whether the remove operation succeeded.
 

Overrides:

remove in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

rename

public void rename(RenamePRequest request,
                   io.grpc.stub.StreamObserver<RenamePResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Renames a file or a directory.
 

Overrides:

rename in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

reverseResolve

public void reverseResolve(ReverseResolvePRequest request,
                           io.grpc.stub.StreamObserver<ReverseResolvePResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Reverse resolve a ufs path.
 

Overrides:

reverseResolve in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

scheduleAsyncPersistence

public void scheduleAsyncPersistence(ScheduleAsyncPersistencePRequest request,
                                     io.grpc.stub.StreamObserver<ScheduleAsyncPersistencePResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Schedules async persistence.
 

Overrides:

scheduleAsyncPersistence in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

setAttribute

public void setAttribute(SetAttributePRequest request,
                         io.grpc.stub.StreamObserver<SetAttributePResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Sets file or directory attributes.
 

Overrides:

setAttribute in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

startSync

public void startSync(StartSyncPRequest request,
                      io.grpc.stub.StreamObserver<StartSyncPResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Start the active syncing of the directory or file
 

Overrides:

startSync in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

stopSync

public void stopSync(StopSyncPRequest request,
                     io.grpc.stub.StreamObserver<StopSyncPResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Start the active syncing of the directory or file
 

Overrides:

stopSync in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

unmount

public void unmount(UnmountPRequest request,
                    io.grpc.stub.StreamObserver<UnmountPResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Deletes an existing "mount point", voiding the Alluxio namespace at the given path. The path
 should correspond to an existing mount point. Any files in its subtree that are backed by UFS
 will be persisted before they are removed from the Alluxio namespace.
 

Overrides:

unmount in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

updateUfsMode

public void updateUfsMode(UpdateUfsModePRequest request,
                          io.grpc.stub.StreamObserver<UpdateUfsModePResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Updates the ufs mode for a ufs path under one or more mount points.
 

Overrides:

updateUfsMode in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

setAcl

public void setAcl(SetAclPRequest request,
                   io.grpc.stub.StreamObserver<SetAclPResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Sets ACL for the path.
 

Overrides:

setAcl in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

getStateLockHolders

public void getStateLockHolders(GetStateLockHoldersPRequest request,
                                io.grpc.stub.StreamObserver<GetStateLockHoldersPResponse> responseObserver)

Overrides:

getStateLockHolders in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

needsSync

public void needsSync(NeedsSyncRequest request,
                      io.grpc.stub.StreamObserver<NeedsSyncResponse> responseObserver)

Overrides:

needsSync in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

submitJob

public void submitJob(SubmitJobPRequest request,
                      io.grpc.stub.StreamObserver<SubmitJobPResponse> responseObserver)

Description copied from class: FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

 Load a directory into Alluxio.
 

Overrides:

submitJob in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

stopJob

public void stopJob(StopJobPRequest request,
                    io.grpc.stub.StreamObserver<StopJobPResponse> responseObserver)

Overrides:

stopJob in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase

getJobProgress

public void getJobProgress(GetJobProgressPRequest request,
                           io.grpc.stub.StreamObserver<GetJobProgressPResponse> responseObserver)

Overrides:

getJobProgress in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase