public final class FileSystemMasterClientServiceHandler extends FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Constructor and Description |
---|
FileSystemMasterClientServiceHandler(FileSystemMaster fileSystemMaster)
Creates a new instance of
FileSystemMasterClientServiceHandler . |
Modifier and Type | Method and Description |
---|---|
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 |
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 |
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 |
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 |
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 |
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 |
stopSync(StopSyncPRequest request,
io.grpc.stub.StreamObserver<StopSyncPResponse> responseObserver)
Start the active syncing of the directory or file
|
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.
|
bindService
public FileSystemMasterClientServiceHandler(FileSystemMaster fileSystemMaster)
FileSystemMasterClientServiceHandler
.fileSystemMaster
- the FileSystemMaster
the handler uses internallypublic void checkConsistency(CheckConsistencyPRequest request, io.grpc.stub.StreamObserver<CheckConsistencyPResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Checks the consistency of the files and directores with the path as the root of the subtree
public void completeFile(CompleteFilePRequest request, io.grpc.stub.StreamObserver<CompleteFilePResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Marks a file as completed.
completeFile
in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
public void createDirectory(CreateDirectoryPRequest request, io.grpc.stub.StreamObserver<CreateDirectoryPResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Creates a directory.
public void createFile(CreateFilePRequest request, io.grpc.stub.StreamObserver<CreateFilePResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Creates a file.
createFile
in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
public void free(FreePRequest request, io.grpc.stub.StreamObserver<FreePResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Frees the given file or directory from Alluxio.
free
in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
public void getNewBlockIdForFile(GetNewBlockIdForFilePRequest request, io.grpc.stub.StreamObserver<GetNewBlockIdForFilePResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Generates a new block id for the given file.
public void getFilePath(GetFilePathPRequest request, io.grpc.stub.StreamObserver<GetFilePathPResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Returns the file path of a file id
getFilePath
in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
public void getStatus(GetStatusPRequest request, io.grpc.stub.StreamObserver<GetStatusPResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Returns the status of the file or directory.
getStatus
in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
public void listStatus(ListStatusPRequest request, io.grpc.stub.StreamObserver<ListStatusPResponse> responseObserver)
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.
listStatus
in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
public void mount(MountPRequest request, io.grpc.stub.StreamObserver<MountPResponse> responseObserver)
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.
mount
in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
public void updateMount(UpdateMountPRequest request, io.grpc.stub.StreamObserver<UpdateMountPResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Updates an existing "mount point", changing its mount properties
updateMount
in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
public void getMountTable(GetMountTablePRequest request, io.grpc.stub.StreamObserver<GetMountTablePResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Returns a map from each Alluxio path to information of corresponding mount point
getMountTable
in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
public void getSyncPathList(GetSyncPathListPRequest request, io.grpc.stub.StreamObserver<GetSyncPathListPResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Returns a list of paths that are being actively synced by Alluxio
public void remove(DeletePRequest request, io.grpc.stub.StreamObserver<DeletePResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Deletes a file or a directory and returns whether the remove operation succeeded.
remove
in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
public void rename(RenamePRequest request, io.grpc.stub.StreamObserver<RenamePResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Renames a file or a directory.
rename
in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
public void reverseResolve(ReverseResolvePRequest request, io.grpc.stub.StreamObserver<ReverseResolvePResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Reverse resolve a ufs path.
public void scheduleAsyncPersistence(ScheduleAsyncPersistencePRequest request, io.grpc.stub.StreamObserver<ScheduleAsyncPersistencePResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Schedules async persistence.
public void setAttribute(SetAttributePRequest request, io.grpc.stub.StreamObserver<SetAttributePResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Sets file or directory attributes.
setAttribute
in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
public void startSync(StartSyncPRequest request, io.grpc.stub.StreamObserver<StartSyncPResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Start the active syncing of the directory or file
startSync
in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
public void stopSync(StopSyncPRequest request, io.grpc.stub.StreamObserver<StopSyncPResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Start the active syncing of the directory or file
stopSync
in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
public void unmount(UnmountPRequest request, io.grpc.stub.StreamObserver<UnmountPResponse> responseObserver)
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.
unmount
in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
public void updateUfsMode(UpdateUfsModePRequest request, io.grpc.stub.StreamObserver<UpdateUfsModePResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Updates the ufs mode for a ufs path under one or more mount points.
updateUfsMode
in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
public void setAcl(SetAclPRequest request, io.grpc.stub.StreamObserver<SetAclPResponse> responseObserver)
FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Sets ACL for the path.
setAcl
in class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceImplBase
Copyright © 2023. All Rights Reserved.