alluxio.master.job

Class JobMasterWorkerServiceHandler

java.lang.Object

alluxio.grpc.JobMasterWorkerServiceGrpc.JobMasterWorkerServiceImplBase

alluxio.master.job.JobMasterWorkerServiceHandler

All Implemented Interfaces:

io.grpc.BindableService

@ThreadSafe
public final class JobMasterWorkerServiceHandler
extends JobMasterWorkerServiceGrpc.JobMasterWorkerServiceImplBase

This class is a gRPC handler for job master RPCs invoked by a job service worker.

Constructor Summary

Constructors

Constructor and Description
JobMasterWorkerServiceHandler(JobMaster JobMaster) Creates a new instance of JobMasterWorkerServiceHandler.

Method Summary

Modifier and Type	Method and Description
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 alluxio.grpc.JobMasterWorkerServiceGrpc.JobMasterWorkerServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

JobMasterWorkerServiceHandler

public JobMasterWorkerServiceHandler(JobMaster JobMaster)

Creates a new instance of JobMasterWorkerServiceHandler.

Parameters:

JobMaster - the JobMaster that the handler uses internally

Method Detail

heartbeat

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

Description copied from class: JobMasterWorkerServiceGrpc.JobMasterWorkerServiceImplBase

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

Overrides:

heartbeat in class JobMasterWorkerServiceGrpc.JobMasterWorkerServiceImplBase

registerJobWorker

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

Description copied from class: JobMasterWorkerServiceGrpc.JobMasterWorkerServiceImplBase

 Returns a worker id for the given network address.
 

Overrides:

registerJobWorker in class JobMasterWorkerServiceGrpc.JobMasterWorkerServiceImplBase