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