public static final class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceFutureStub extends io.grpc.stub.AbstractFutureStub<FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceFutureStub>
This interface contains file system master service endpoints for Alluxio clients.
Modifier and Type | Method and Description |
---|---|
protected FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceFutureStub |
build(io.grpc.Channel channel,
io.grpc.CallOptions callOptions) |
com.google.common.util.concurrent.ListenableFuture<CheckAccessPResponse> |
checkAccess(CheckAccessPRequest request)
Checks access to path.
|
com.google.common.util.concurrent.ListenableFuture<CheckConsistencyPResponse> |
checkConsistency(CheckConsistencyPRequest request)
Checks the consistency of the files and directores with the path as the root of the subtree
|
com.google.common.util.concurrent.ListenableFuture<CompleteFilePResponse> |
completeFile(CompleteFilePRequest request)
Marks a file as completed.
|
com.google.common.util.concurrent.ListenableFuture<CreateDirectoryPResponse> |
createDirectory(CreateDirectoryPRequest request)
Creates a directory.
|
com.google.common.util.concurrent.ListenableFuture<CreateFilePResponse> |
createFile(CreateFilePRequest request)
Creates a file.
|
com.google.common.util.concurrent.ListenableFuture<FreePResponse> |
free(FreePRequest request)
Frees the given file or directory from Alluxio.
|
com.google.common.util.concurrent.ListenableFuture<GetFilePathPResponse> |
getFilePath(GetFilePathPRequest request)
Returns the file path of a file id
|
com.google.common.util.concurrent.ListenableFuture<GetMountTablePResponse> |
getMountTable(GetMountTablePRequest request)
Returns a map from each Alluxio path to information of corresponding mount point
|
com.google.common.util.concurrent.ListenableFuture<GetNewBlockIdForFilePResponse> |
getNewBlockIdForFile(GetNewBlockIdForFilePRequest request)
Generates a new block id for the given file.
|
com.google.common.util.concurrent.ListenableFuture<GetStateLockHoldersPResponse> |
getStateLockHolders(GetStateLockHoldersPRequest request) |
com.google.common.util.concurrent.ListenableFuture<GetStatusPResponse> |
getStatus(GetStatusPRequest request)
Returns the status of the file or directory.
|
com.google.common.util.concurrent.ListenableFuture<GetSyncPathListPResponse> |
getSyncPathList(GetSyncPathListPRequest request)
Returns a list of paths that are being actively synced by Alluxio
|
com.google.common.util.concurrent.ListenableFuture<MountPResponse> |
mount(MountPRequest request)
Creates a new "mount point", mounts the given UFS path in the Alluxio namespace at the given
path.
|
com.google.common.util.concurrent.ListenableFuture<DeletePResponse> |
remove(DeletePRequest request)
Deletes a file or a directory and returns whether the remove operation succeeded.
|
com.google.common.util.concurrent.ListenableFuture<RenamePResponse> |
rename(RenamePRequest request)
Renames a file or a directory.
|
com.google.common.util.concurrent.ListenableFuture<ReverseResolvePResponse> |
reverseResolve(ReverseResolvePRequest request)
Reverse resolve a ufs path.
|
com.google.common.util.concurrent.ListenableFuture<ScheduleAsyncPersistencePResponse> |
scheduleAsyncPersistence(ScheduleAsyncPersistencePRequest request)
Schedules async persistence.
|
com.google.common.util.concurrent.ListenableFuture<SetAclPResponse> |
setAcl(SetAclPRequest request)
Sets ACL for the path.
|
com.google.common.util.concurrent.ListenableFuture<SetAttributePResponse> |
setAttribute(SetAttributePRequest request)
Sets file or directory attributes.
|
com.google.common.util.concurrent.ListenableFuture<StartSyncPResponse> |
startSync(StartSyncPRequest request)
Start the active syncing of the directory or file
|
com.google.common.util.concurrent.ListenableFuture<StopSyncPResponse> |
stopSync(StopSyncPRequest request)
Start the active syncing of the directory or file
|
com.google.common.util.concurrent.ListenableFuture<UnmountPResponse> |
unmount(UnmountPRequest request)
Deletes an existing "mount point", voiding the Alluxio namespace at the given path.
|
com.google.common.util.concurrent.ListenableFuture<UpdateMountPResponse> |
updateMount(UpdateMountPRequest request)
Updates an existing "mount point", changing its mount properties
|
com.google.common.util.concurrent.ListenableFuture<UpdateUfsModePResponse> |
updateUfsMode(UpdateUfsModePRequest request)
Updates the ufs mode for a ufs path under one or more mount points.
|
protected FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
build
in class io.grpc.stub.AbstractStub<FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceFutureStub>
public com.google.common.util.concurrent.ListenableFuture<CheckAccessPResponse> checkAccess(CheckAccessPRequest request)
Checks access to path.
public com.google.common.util.concurrent.ListenableFuture<CheckConsistencyPResponse> checkConsistency(CheckConsistencyPRequest request)
Checks the consistency of the files and directores with the path as the root of the subtree
public com.google.common.util.concurrent.ListenableFuture<CompleteFilePResponse> completeFile(CompleteFilePRequest request)
Marks a file as completed.
public com.google.common.util.concurrent.ListenableFuture<CreateDirectoryPResponse> createDirectory(CreateDirectoryPRequest request)
Creates a directory.
public com.google.common.util.concurrent.ListenableFuture<CreateFilePResponse> createFile(CreateFilePRequest request)
Creates a file.
public com.google.common.util.concurrent.ListenableFuture<FreePResponse> free(FreePRequest request)
Frees the given file or directory from Alluxio.
public com.google.common.util.concurrent.ListenableFuture<GetFilePathPResponse> getFilePath(GetFilePathPRequest request)
Returns the file path of a file id
public com.google.common.util.concurrent.ListenableFuture<GetMountTablePResponse> getMountTable(GetMountTablePRequest request)
Returns a map from each Alluxio path to information of corresponding mount point
public com.google.common.util.concurrent.ListenableFuture<GetSyncPathListPResponse> getSyncPathList(GetSyncPathListPRequest request)
Returns a list of paths that are being actively synced by Alluxio
public com.google.common.util.concurrent.ListenableFuture<GetNewBlockIdForFilePResponse> getNewBlockIdForFile(GetNewBlockIdForFilePRequest request)
Generates a new block id for the given file.
public com.google.common.util.concurrent.ListenableFuture<GetStatusPResponse> getStatus(GetStatusPRequest request)
Returns the status of the file or directory.
public com.google.common.util.concurrent.ListenableFuture<MountPResponse> mount(MountPRequest request)
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 com.google.common.util.concurrent.ListenableFuture<DeletePResponse> remove(DeletePRequest request)
Deletes a file or a directory and returns whether the remove operation succeeded.
public com.google.common.util.concurrent.ListenableFuture<RenamePResponse> rename(RenamePRequest request)
Renames a file or a directory.
public com.google.common.util.concurrent.ListenableFuture<ReverseResolvePResponse> reverseResolve(ReverseResolvePRequest request)
Reverse resolve a ufs path.
public com.google.common.util.concurrent.ListenableFuture<ScheduleAsyncPersistencePResponse> scheduleAsyncPersistence(ScheduleAsyncPersistencePRequest request)
Schedules async persistence.
public com.google.common.util.concurrent.ListenableFuture<SetAclPResponse> setAcl(SetAclPRequest request)
Sets ACL for the path.
public com.google.common.util.concurrent.ListenableFuture<SetAttributePResponse> setAttribute(SetAttributePRequest request)
Sets file or directory attributes.
public com.google.common.util.concurrent.ListenableFuture<StartSyncPResponse> startSync(StartSyncPRequest request)
Start the active syncing of the directory or file
public com.google.common.util.concurrent.ListenableFuture<StopSyncPResponse> stopSync(StopSyncPRequest request)
Start the active syncing of the directory or file
public com.google.common.util.concurrent.ListenableFuture<UnmountPResponse> unmount(UnmountPRequest request)
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 com.google.common.util.concurrent.ListenableFuture<UpdateMountPResponse> updateMount(UpdateMountPRequest request)
Updates an existing "mount point", changing its mount properties
public com.google.common.util.concurrent.ListenableFuture<UpdateUfsModePResponse> updateUfsMode(UpdateUfsModePRequest request)
Updates the ufs mode for a ufs path under one or more mount points.
public com.google.common.util.concurrent.ListenableFuture<GetStateLockHoldersPResponse> getStateLockHolders(GetStateLockHoldersPRequest request)
Copyright © 2023. All Rights Reserved.