alluxio.grpc

Class JobMasterWorkerServiceGrpc.JobMasterWorkerServiceBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<JobMasterWorkerServiceGrpc.JobMasterWorkerServiceBlockingStub>

alluxio.grpc.JobMasterWorkerServiceGrpc.JobMasterWorkerServiceBlockingStub

Enclosing class:

JobMasterWorkerServiceGrpc

public static final class JobMasterWorkerServiceGrpc.JobMasterWorkerServiceBlockingStub
extends io.grpc.stub.AbstractStub<JobMasterWorkerServiceGrpc.JobMasterWorkerServiceBlockingStub>

 This interface contains job master service endpoints for job service workers.
 

Method Summary

Modifier and Type	Method and Description
protected JobMasterWorkerServiceGrpc.JobMasterWorkerServiceBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
JobHeartbeatPResponse	heartbeat(JobHeartbeatPRequest request) Periodic worker heartbeat returns a list of commands for the worker to execute.
RegisterJobWorkerPResponse	registerJobWorker(RegisterJobWorkerPRequest request) Returns a worker id for the given network address.

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

Specified by:

build in class io.grpc.stub.AbstractStub<JobMasterWorkerServiceGrpc.JobMasterWorkerServiceBlockingStub>

heartbeat

public JobHeartbeatPResponse heartbeat(JobHeartbeatPRequest request)

 Periodic worker heartbeat returns a list of commands for the worker to execute.
 

registerJobWorker

public RegisterJobWorkerPResponse registerJobWorker(RegisterJobWorkerPRequest request)

 Returns a worker id for the given network address.