alluxio.grpc

Class JobMasterWorkerServiceGrpc.JobMasterWorkerServiceImplBase

java.lang.Object

alluxio.grpc.JobMasterWorkerServiceGrpc.JobMasterWorkerServiceImplBase

All Implemented Interfaces:

io.grpc.BindableService

Direct Known Subclasses:

JobMasterWorkerServiceHandler

Enclosing class:

JobMasterWorkerServiceGrpc

public abstract static class JobMasterWorkerServiceGrpc.JobMasterWorkerServiceImplBase
extends Object
implements io.grpc.BindableService

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

Constructor Summary

Constructors

Constructor and Description
JobMasterWorkerServiceImplBase()

Method Summary

Modifier and Type	Method and Description
io.grpc.ServerServiceDefinition	bindService()
void	heartbeat(JobHeartbeatPRequest request, io.grpc.stub.StreamObserver<JobHeartbeatPResponse> responseObserver) Periodic worker heartbeat returns a list of commands for the worker to execute.
void	registerJobWorker(RegisterJobWorkerPRequest request, io.grpc.stub.StreamObserver<RegisterJobWorkerPResponse> responseObserver) Returns a worker id for the given network address.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobMasterWorkerServiceImplBase

public JobMasterWorkerServiceImplBase()

Method Detail

heartbeat

public void heartbeat(JobHeartbeatPRequest request,
                      io.grpc.stub.StreamObserver<JobHeartbeatPResponse> responseObserver)

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

registerJobWorker

public void registerJobWorker(RegisterJobWorkerPRequest request,
                              io.grpc.stub.StreamObserver<RegisterJobWorkerPResponse> responseObserver)

 Returns a worker id for the given network address.
 

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService