alluxio.grpc

Class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceBlockingStub>

alluxio.grpc.BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceBlockingStub

Enclosing class:

BlockMasterWorkerServiceGrpc

public static final class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceBlockingStub
extends io.grpc.stub.AbstractBlockingStub<BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceBlockingStub>

 This interface contains block master service endpoints for Alluxio workers.
 

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
BlockHeartbeatPResponse	blockHeartbeat(BlockHeartbeatPRequest request) Periodic block worker heartbeat returns an optional command for the block worker to execute.
protected BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
CommitBlockPResponse	commitBlock(CommitBlockPRequest request) Marks the given block as committed.
CommitBlockInUfsPResponse	commitBlockInUfs(CommitBlockInUfsPRequest request) Marks the given block as committed which resides in UFS.
GetWorkerIdPResponse	getWorkerId(GetWorkerIdPRequest request) Returns a worker id for the given network address.
RegisterWorkerPResponse	registerWorker(RegisterWorkerPRequest request) Registers a worker.

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

Specified by:

build in class io.grpc.stub.AbstractStub<BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceBlockingStub>

blockHeartbeat

public BlockHeartbeatPResponse blockHeartbeat(BlockHeartbeatPRequest request)

 Periodic block worker heartbeat returns an optional command for the block worker to execute.
 

commitBlock

public CommitBlockPResponse commitBlock(CommitBlockPRequest request)

 Marks the given block as committed.
 

commitBlockInUfs

public CommitBlockInUfsPResponse commitBlockInUfs(CommitBlockInUfsPRequest request)

 Marks the given block as committed which resides in UFS.
 

getWorkerId

public GetWorkerIdPResponse getWorkerId(GetWorkerIdPRequest request)

 Returns a worker id for the given network address.
 

registerWorker

public RegisterWorkerPResponse registerWorker(RegisterWorkerPRequest request)

 Registers a worker.