alluxio.grpc

Class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceBlockingStub>

alluxio.grpc.FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceBlockingStub

Enclosing class:

FileSystemMasterClientServiceGrpc

public static final class FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceBlockingStub
extends io.grpc.stub.AbstractBlockingStub<FileSystemMasterClientServiceGrpc.FileSystemMasterClientServiceBlockingStub>

A stub to allow clients to do synchronous 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.FileSystemMasterClientServiceBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
CheckAccessPResponse	checkAccess(CheckAccessPRequest request) Checks access to path.
CheckConsistencyPResponse	checkConsistency(CheckConsistencyPRequest request) Checks the consistency of the files and directores with the path as the root of the subtree
CompleteFilePResponse	completeFile(CompleteFilePRequest request) Marks a file as completed.
CreateDirectoryPResponse	createDirectory(CreateDirectoryPRequest request) Creates a directory.
CreateFilePResponse	createFile(CreateFilePRequest request) Creates a file.
ExistsPResponse	exists(ExistsPRequest request) Checks the existence of the file or directory.
FreePResponse	free(FreePRequest request) Frees the given file or directory from Alluxio.
GetFilePathPResponse	getFilePath(GetFilePathPRequest request) Returns the file path of a file id
GetJobProgressPResponse	getJobProgress(GetJobProgressPRequest request)
GetMountIdPResponse	getMountId(GetMountIdPRequest request) Reverse resolve a ufs path and get mount id.
GetMountTablePResponse	getMountTable(GetMountTablePRequest request) Returns a map from each Alluxio path to information of corresponding mount point
GetNewBlockIdForFilePResponse	getNewBlockIdForFile(GetNewBlockIdForFilePRequest request) Generates a new block id for the given file.
GetStateLockHoldersPResponse	getStateLockHolders(GetStateLockHoldersPRequest request)
GetStatusPResponse	getStatus(GetStatusPRequest request) Returns the status of the file or directory.
Iterator<ListStatusPResponse>	listStatus(ListStatusPRequest request) If the path points to a file, the method returns a singleton with its file information.
ListStatusPartialPResponse	listStatusPartial(ListStatusPartialPRequest request) If the path points to a file, the method returns a singleton with its file information.
MountPResponse	mount(MountPRequest request) Creates a new "mount point", mounts the given UFS path in the Alluxio namespace at the given path.
NeedsSyncResponse	needsSync(NeedsSyncRequest request)
DeletePResponse	remove(DeletePRequest request) Deletes a file or a directory and returns whether the remove operation succeeded.
RenamePResponse	rename(RenamePRequest request) Renames a file or a directory.
ReverseResolvePResponse	reverseResolve(ReverseResolvePRequest request) Reverse resolve a ufs path.
ScheduleAsyncPersistencePResponse	scheduleAsyncPersistence(ScheduleAsyncPersistencePRequest request) Schedules async persistence.
SetAclPResponse	setAcl(SetAclPRequest request) Sets ACL for the path.
SetAttributePResponse	setAttribute(SetAttributePRequest request) Sets file or directory attributes.
StopJobPResponse	stopJob(StopJobPRequest request)
SubmitJobPResponse	submitJob(SubmitJobPRequest request) Load a directory into Alluxio.
UnmountPResponse	unmount(UnmountPRequest request) Deletes an existing "mount point", voiding the Alluxio namespace at the given path.
UpdateMountPResponse	updateMount(UpdateMountPRequest request) Updates an existing "mount point", changing its mount properties
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.AbstractBlockingStub

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.FileSystemMasterClientServiceBlockingStub build(io.grpc.Channel channel,
                                                                                            io.grpc.CallOptions callOptions)

Specified by:

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

checkAccess

public CheckAccessPResponse checkAccess(CheckAccessPRequest request)

 Checks access to path.
 

checkConsistency

public CheckConsistencyPResponse checkConsistency(CheckConsistencyPRequest request)

 Checks the consistency of the files and directores with the path as the root of the subtree
 

exists

public ExistsPResponse exists(ExistsPRequest request)

 Checks the existence of the file or directory.
 

completeFile

public CompleteFilePResponse completeFile(CompleteFilePRequest request)

 Marks a file as completed.
 

createDirectory

public CreateDirectoryPResponse createDirectory(CreateDirectoryPRequest request)

 Creates a directory.
 

createFile

public CreateFilePResponse createFile(CreateFilePRequest request)

 Creates a file.
 

free

public FreePResponse free(FreePRequest request)

 Frees the given file or directory from Alluxio.
 

getFilePath

public GetFilePathPResponse getFilePath(GetFilePathPRequest request)

 Returns the file path of a file id
 

getMountTable

public GetMountTablePResponse getMountTable(GetMountTablePRequest request)

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

getNewBlockIdForFile

public GetNewBlockIdForFilePResponse getNewBlockIdForFile(GetNewBlockIdForFilePRequest request)

 Generates a new block id for the given file.
 

getStatus

public GetStatusPResponse getStatus(GetStatusPRequest request)

 Returns the status of the file or directory.
 

listStatus

public Iterator<ListStatusPResponse> listStatus(ListStatusPRequest 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.
 

listStatusPartial

public 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 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 DeletePResponse remove(DeletePRequest request)

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

rename

public RenamePResponse rename(RenamePRequest request)

 Renames a file or a directory.
 

reverseResolve

public ReverseResolvePResponse reverseResolve(ReverseResolvePRequest request)

 Reverse resolve a ufs path.
 

getMountId

public GetMountIdPResponse getMountId(GetMountIdPRequest request)

 Reverse resolve a ufs path and get mount id.
 

scheduleAsyncPersistence

public ScheduleAsyncPersistencePResponse scheduleAsyncPersistence(ScheduleAsyncPersistencePRequest request)

 Schedules async persistence.
 

setAcl

public SetAclPResponse setAcl(SetAclPRequest request)

 Sets ACL for the path.
 

setAttribute

public SetAttributePResponse setAttribute(SetAttributePRequest request)

 Sets file or directory attributes.
 

unmount

public 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 UpdateMountPResponse updateMount(UpdateMountPRequest request)

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

updateUfsMode

public UpdateUfsModePResponse updateUfsMode(UpdateUfsModePRequest request)

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

getStateLockHolders

public GetStateLockHoldersPResponse getStateLockHolders(GetStateLockHoldersPRequest request)

needsSync

public NeedsSyncResponse needsSync(NeedsSyncRequest request)

submitJob

public SubmitJobPResponse submitJob(SubmitJobPRequest request)

 Load a directory into Alluxio.
 

stopJob

public StopJobPResponse stopJob(StopJobPRequest request)

getJobProgress

public GetJobProgressPResponse getJobProgress(GetJobProgressPRequest request)