Package org.apache.nemo.runtime.common.comm

Class MessageServiceGrpc.MessageServiceImplBase

java.lang.Object

org.apache.nemo.runtime.common.comm.MessageServiceGrpc.MessageServiceImplBase

All Implemented Interfaces:

io.grpc.BindableService

Enclosing class:

MessageServiceGrpc

public abstract static class MessageServiceGrpc.MessageServiceImplBase
extends java.lang.Object
implements io.grpc.BindableService

 A grpc service for implementing org.apache.nemo.runtime.common.message components using grpc
 

Constructor Summary

Constructors

Constructor	Description
MessageServiceImplBase()

Method Summary

Modifier and Type	Method	Description
io.grpc.ServerServiceDefinition	bindService()
void	request(ControlMessage.Message request, io.grpc.stub.StreamObserver<ControlMessage.Message> responseObserver)	See org.apache.nemo.runtime.common.message.MessageSender#request for more details
void	send(ControlMessage.Message request, io.grpc.stub.StreamObserver<GrpcMessageService.Void> responseObserver)	See org.apache.nemo.runtime.common.message.MessageSender#send for more details

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageServiceImplBase

public MessageServiceImplBase()

Method Detail

send

public void send(ControlMessage.Message request,
                 io.grpc.stub.StreamObserver<GrpcMessageService.Void> responseObserver)

 See org.apache.nemo.runtime.common.message.MessageSender#send for more details
 

request

public void request(ControlMessage.Message request,
                    io.grpc.stub.StreamObserver<ControlMessage.Message> responseObserver)

 See org.apache.nemo.runtime.common.message.MessageSender#request for more details
 

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService