alluxio.grpc

Class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractFutureStub<FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceFutureStub>

alluxio.grpc.FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceFutureStub

Enclosing class:

FileSystemMasterClientServiceGrpc

public static final class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceFutureStub>

A stub to allow clients to do ListenableFuture-style rpc calls to service FileSystemMasterClientService.

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

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

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<ExistsPResponse>	exists(ExistsPRequest request) Checks the existence of the file or directory.
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<GetJobProgressPResponse>	getJobProgress(GetJobProgressPRequest request)
com.google.common.util.concurrent.ListenableFuture<GetMountIdPResponse>	getMountId(GetMountIdPRequest request) Reverse resolve a ufs path and get mount 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<ListStatusPartialPResponse>	listStatusPartial(ListStatusPartialPRequest request) If the path points to a file, the method returns a singleton with its file information.
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<NeedsSyncResponse>	needsSync(NeedsSyncRequest request)
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<StopJobPResponse>	stopJob(StopJobPRequest request)
com.google.common.util.concurrent.ListenableFuture<SubmitJobPResponse>	submitJob(SubmitJobPRequest request) Load a directory into Alluxio.
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.

Methods inherited from class io.grpc.stub.AbstractFutureStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Detail

build

protected FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceFutureStub build(io.grpc.Channel channel,
                                                                                          io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceFutureStub>

checkAccess

public com.google.common.util.concurrent.ListenableFuture<CheckAccessPResponse> checkAccess(CheckAccessPRequest request)

 Checks access to path.
 

checkConsistency

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
 

exists

public com.google.common.util.concurrent.ListenableFuture<ExistsPResponse> exists(ExistsPRequest request)

 Checks the existence of the file or directory.
 

completeFile

public com.google.common.util.concurrent.ListenableFuture<CompleteFilePResponse> completeFile(CompleteFilePRequest request)

 Marks a file as completed.
 

createDirectory

public com.google.common.util.concurrent.ListenableFuture<CreateDirectoryPResponse> createDirectory(CreateDirectoryPRequest request)

 Creates a directory.
 

createFile

public com.google.common.util.concurrent.ListenableFuture<CreateFilePResponse> createFile(CreateFilePRequest request)

 Creates a file.
 

free

public com.google.common.util.concurrent.ListenableFuture<FreePResponse> free(FreePRequest request)

 Frees the given file or directory from Alluxio.
 

getFilePath

public com.google.common.util.concurrent.ListenableFuture<GetFilePathPResponse> getFilePath(GetFilePathPRequest request)

 Returns the file path of a file id
 

getMountTable

public com.google.common.util.concurrent.ListenableFuture<GetMountTablePResponse> getMountTable(GetMountTablePRequest request)

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

getNewBlockIdForFile

public com.google.common.util.concurrent.ListenableFuture<GetNewBlockIdForFilePResponse> getNewBlockIdForFile(GetNewBlockIdForFilePRequest request)

 Generates a new block id for the given file.
 

getStatus

public com.google.common.util.concurrent.ListenableFuture<GetStatusPResponse> getStatus(GetStatusPRequest request)

 Returns the status of the file or directory.
 

listStatusPartial

public com.google.common.util.concurrent.ListenableFuture<ListStatusPartialPResponse> listStatusPartial(ListStatusPartialPRequest request)

 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

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.
 

remove

public com.google.common.util.concurrent.ListenableFuture<DeletePResponse> remove(DeletePRequest request)

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

rename

public com.google.common.util.concurrent.ListenableFuture<RenamePResponse> rename(RenamePRequest request)

 Renames a file or a directory.
 

reverseResolve

public com.google.common.util.concurrent.ListenableFuture<ReverseResolvePResponse> reverseResolve(ReverseResolvePRequest request)

 Reverse resolve a ufs path.
 

getMountId

public com.google.common.util.concurrent.ListenableFuture<GetMountIdPResponse> getMountId(GetMountIdPRequest request)

 Reverse resolve a ufs path and get mount id.
 

scheduleAsyncPersistence

public com.google.common.util.concurrent.ListenableFuture<ScheduleAsyncPersistencePResponse> scheduleAsyncPersistence(ScheduleAsyncPersistencePRequest request)

 Schedules async persistence.
 

setAcl

public com.google.common.util.concurrent.ListenableFuture<SetAclPResponse> setAcl(SetAclPRequest request)

 Sets ACL for the path.
 

setAttribute

public com.google.common.util.concurrent.ListenableFuture<SetAttributePResponse> setAttribute(SetAttributePRequest request)

 Sets file or directory attributes.
 

unmount

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.
 

updateMount

public com.google.common.util.concurrent.ListenableFuture<UpdateMountPResponse> updateMount(UpdateMountPRequest request)

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

updateUfsMode

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.
 

getStateLockHolders

public com.google.common.util.concurrent.ListenableFuture<GetStateLockHoldersPResponse> getStateLockHolders(GetStateLockHoldersPRequest request)

needsSync

public com.google.common.util.concurrent.ListenableFuture<NeedsSyncResponse> needsSync(NeedsSyncRequest request)

submitJob

public com.google.common.util.concurrent.ListenableFuture<SubmitJobPResponse> submitJob(SubmitJobPRequest request)

 Load a directory into Alluxio.
 

stopJob

public com.google.common.util.concurrent.ListenableFuture<StopJobPResponse> stopJob(StopJobPRequest request)

getJobProgress

public com.google.common.util.concurrent.ListenableFuture<GetJobProgressPResponse> getJobProgress(GetJobProgressPRequest request)