alluxio.grpc

Interface FileSystemMasterClientServiceGrpc.AsyncService

All Known Implementing Classes:

FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase, FileSystemMasterClientServiceHandler

Enclosing class:

FileSystemMasterClientServiceGrpc

public static interface FileSystemMasterClientServiceGrpc.AsyncService

 This interface contains file system master service endpoints for Alluxio clients.
 

Method Summary

Modifier and Type	Method and Description
default void	checkAccess(CheckAccessPRequest request, io.grpc.stub.StreamObserver<CheckAccessPResponse> responseObserver) Checks access to path.
default 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
default void	completeFile(CompleteFilePRequest request, io.grpc.stub.StreamObserver<CompleteFilePResponse> responseObserver) Marks a file as completed.
default void	createDirectory(CreateDirectoryPRequest request, io.grpc.stub.StreamObserver<CreateDirectoryPResponse> responseObserver) Creates a directory.
default void	createFile(CreateFilePRequest request, io.grpc.stub.StreamObserver<CreateFilePResponse> responseObserver) Creates a file.
default void	exists(ExistsPRequest request, io.grpc.stub.StreamObserver<ExistsPResponse> responseObserver) Checks the existence of the file or directory.
default void	free(FreePRequest request, io.grpc.stub.StreamObserver<FreePResponse> responseObserver) Frees the given file or directory from Alluxio.
default void	getFilePath(GetFilePathPRequest request, io.grpc.stub.StreamObserver<GetFilePathPResponse> responseObserver) Returns the file path of a file id
default void	getJobProgress(GetJobProgressPRequest request, io.grpc.stub.StreamObserver<GetJobProgressPResponse> responseObserver)
default void	getMountId(GetMountIdPRequest request, io.grpc.stub.StreamObserver<GetMountIdPResponse> responseObserver) Reverse resolve a ufs path and get mount id.
default void	getMountTable(GetMountTablePRequest request, io.grpc.stub.StreamObserver<GetMountTablePResponse> responseObserver) Returns a map from each Alluxio path to information of corresponding mount point
default void	getNewBlockIdForFile(GetNewBlockIdForFilePRequest request, io.grpc.stub.StreamObserver<GetNewBlockIdForFilePResponse> responseObserver) Generates a new block id for the given file.
default void	getStateLockHolders(GetStateLockHoldersPRequest request, io.grpc.stub.StreamObserver<GetStateLockHoldersPResponse> responseObserver)
default void	getStatus(GetStatusPRequest request, io.grpc.stub.StreamObserver<GetStatusPResponse> responseObserver) Returns the status of the file or directory.
default 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.
default 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.
default 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.
default void	needsSync(NeedsSyncRequest request, io.grpc.stub.StreamObserver<NeedsSyncResponse> responseObserver)
default void	remove(DeletePRequest request, io.grpc.stub.StreamObserver<DeletePResponse> responseObserver) Deletes a file or a directory and returns whether the remove operation succeeded.
default void	rename(RenamePRequest request, io.grpc.stub.StreamObserver<RenamePResponse> responseObserver) Renames a file or a directory.
default void	reverseResolve(ReverseResolvePRequest request, io.grpc.stub.StreamObserver<ReverseResolvePResponse> responseObserver) Reverse resolve a ufs path.
default void	scheduleAsyncPersistence(ScheduleAsyncPersistencePRequest request, io.grpc.stub.StreamObserver<ScheduleAsyncPersistencePResponse> responseObserver) Schedules async persistence.
default void	setAcl(SetAclPRequest request, io.grpc.stub.StreamObserver<SetAclPResponse> responseObserver) Sets ACL for the path.
default void	setAttribute(SetAttributePRequest request, io.grpc.stub.StreamObserver<SetAttributePResponse> responseObserver) Sets file or directory attributes.
default void	stopJob(StopJobPRequest request, io.grpc.stub.StreamObserver<StopJobPResponse> responseObserver)
default void	submitJob(SubmitJobPRequest request, io.grpc.stub.StreamObserver<SubmitJobPResponse> responseObserver) Load a directory into Alluxio.
default void	unmount(UnmountPRequest request, io.grpc.stub.StreamObserver<UnmountPResponse> responseObserver) Deletes an existing "mount point", voiding the Alluxio namespace at the given path.
default void	updateMount(UpdateMountPRequest request, io.grpc.stub.StreamObserver<UpdateMountPResponse> responseObserver) Updates an existing "mount point", changing its mount properties
default void	updateUfsMode(UpdateUfsModePRequest request, io.grpc.stub.StreamObserver<UpdateUfsModePResponse> responseObserver) Updates the ufs mode for a ufs path under one or more mount points.

Method Detail

checkAccess

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

 Checks access to path.
 

checkConsistency

default 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
 

exists

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

 Checks the existence of the file or directory.
 

completeFile

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

 Marks a file as completed.
 

createDirectory

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

 Creates a directory.
 

createFile

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

 Creates a file.
 

free

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

 Frees the given file or directory from Alluxio.
 

getFilePath

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

 Returns the file path of a file id
 

getMountTable

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

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

getNewBlockIdForFile

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

 Generates a new block id for the given file.
 

getStatus

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

 Returns the status of the file or directory.
 

listStatus

default 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.
 If the path points to a directory, the method returns a list with file information for the
 directory contents.
 

listStatusPartial

default 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.
 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.
 

mount

default 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. The path should not exist and should not be nested under any existing mount point.
 

remove

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

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

rename

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

 Renames a file or a directory.
 

reverseResolve

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

 Reverse resolve a ufs path.
 

getMountId

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

 Reverse resolve a ufs path and get mount id.
 

scheduleAsyncPersistence

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

 Schedules async persistence.
 

setAcl

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

 Sets ACL for the path.
 

setAttribute

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

 Sets file or directory attributes.
 

unmount

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

 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.
 

updateMount

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

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

updateUfsMode

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

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

getStateLockHolders

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

needsSync

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

submitJob

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

 Load a directory into Alluxio.
 

stopJob

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

getJobProgress

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