Uses of Class
org.apache.nemo.runtime.common.comm.ControlMessage.Message

Packages that use ControlMessage.Message

Package	Description
org.apache.nemo.runtime.common.comm
org.apache.nemo.runtime.common.message
org.apache.nemo.runtime.master
org.apache.nemo.runtime.master.resource

Uses of ControlMessage.Message in org.apache.nemo.runtime.common.comm

Fields in org.apache.nemo.runtime.common.comm with type parameters of type ControlMessage.Message

Modifier and Type	Field	Description
static com.google.protobuf.Parser<ControlMessage.Message>	ControlMessage.Message.PARSER	Deprecated.

Methods in org.apache.nemo.runtime.common.comm that return ControlMessage.Message

Modifier and Type	Method	Description
ControlMessage.Message	ControlMessage.Message.Builder.build()
ControlMessage.Message	ControlMessage.Message.Builder.buildPartial()
static ControlMessage.Message	ControlMessage.Message.getDefaultInstance()
ControlMessage.Message	ControlMessage.Message.Builder.getDefaultInstanceForType()
ControlMessage.Message	ControlMessage.Message.getDefaultInstanceForType()
static ControlMessage.Message	ControlMessage.Message.parseDelimitedFrom(java.io.InputStream input)
static ControlMessage.Message	ControlMessage.Message.parseDelimitedFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ControlMessage.Message	ControlMessage.Message.parseFrom(byte[] data)
static ControlMessage.Message	ControlMessage.Message.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ControlMessage.Message	ControlMessage.Message.parseFrom(com.google.protobuf.ByteString data)
static ControlMessage.Message	ControlMessage.Message.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ControlMessage.Message	ControlMessage.Message.parseFrom(com.google.protobuf.CodedInputStream input)
static ControlMessage.Message	ControlMessage.Message.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ControlMessage.Message	ControlMessage.Message.parseFrom(java.io.InputStream input)
static ControlMessage.Message	ControlMessage.Message.parseFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ControlMessage.Message	ControlMessage.Message.parseFrom(java.nio.ByteBuffer data)
static ControlMessage.Message	ControlMessage.Message.parseFrom(java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
ControlMessage.Message	MessageServiceGrpc.MessageServiceBlockingStub.request(ControlMessage.Message request)	See org.apache.nemo.runtime.common.message.MessageSender#request for more details

Methods in org.apache.nemo.runtime.common.comm that return types with arguments of type ControlMessage.Message

Modifier and Type	Method	Description
com.google.protobuf.Parser<ControlMessage.Message>	ControlMessage.Message.getParserForType()
static io.grpc.MethodDescriptor<ControlMessage.Message,ControlMessage.Message>	MessageServiceGrpc.getRequestMethod()
static io.grpc.MethodDescriptor<ControlMessage.Message,ControlMessage.Message>	MessageServiceGrpc.getRequestMethod()
static io.grpc.MethodDescriptor<ControlMessage.Message,GrpcMessageService.Void>	MessageServiceGrpc.getSendMethod()
static com.google.protobuf.Parser<ControlMessage.Message>	ControlMessage.Message.parser()
com.google.common.util.concurrent.ListenableFuture<ControlMessage.Message>	MessageServiceGrpc.MessageServiceFutureStub.request(ControlMessage.Message request)	See org.apache.nemo.runtime.common.message.MessageSender#request for more details

Methods in org.apache.nemo.runtime.common.comm with parameters of type ControlMessage.Message

Modifier and Type	Method	Description
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeFrom(ControlMessage.Message other)
static ControlMessage.Message.Builder	ControlMessage.Message.newBuilder(ControlMessage.Message prototype)
ControlMessage.Message	MessageServiceGrpc.MessageServiceBlockingStub.request(ControlMessage.Message request)	See org.apache.nemo.runtime.common.message.MessageSender#request for more details
com.google.common.util.concurrent.ListenableFuture<ControlMessage.Message>	MessageServiceGrpc.MessageServiceFutureStub.request(ControlMessage.Message request)	See org.apache.nemo.runtime.common.message.MessageSender#request for more details
void	MessageServiceGrpc.MessageServiceImplBase.request(ControlMessage.Message request, io.grpc.stub.StreamObserver<ControlMessage.Message> responseObserver)	See org.apache.nemo.runtime.common.message.MessageSender#request for more details
void	MessageServiceGrpc.MessageServiceStub.request(ControlMessage.Message request, io.grpc.stub.StreamObserver<ControlMessage.Message> responseObserver)	See org.apache.nemo.runtime.common.message.MessageSender#request for more details
GrpcMessageService.Void	MessageServiceGrpc.MessageServiceBlockingStub.send(ControlMessage.Message request)	See org.apache.nemo.runtime.common.message.MessageSender#send for more details
com.google.common.util.concurrent.ListenableFuture<GrpcMessageService.Void>	MessageServiceGrpc.MessageServiceFutureStub.send(ControlMessage.Message request)	See org.apache.nemo.runtime.common.message.MessageSender#send for more details
void	MessageServiceGrpc.MessageServiceImplBase.send(ControlMessage.Message request, io.grpc.stub.StreamObserver<GrpcMessageService.Void> responseObserver)	See org.apache.nemo.runtime.common.message.MessageSender#send for more details
void	MessageServiceGrpc.MessageServiceStub.send(ControlMessage.Message request, io.grpc.stub.StreamObserver<GrpcMessageService.Void> responseObserver)	See org.apache.nemo.runtime.common.message.MessageSender#send for more details

Method parameters in org.apache.nemo.runtime.common.comm with type arguments of type ControlMessage.Message

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

Uses of ControlMessage.Message in org.apache.nemo.runtime.common.message

Methods in org.apache.nemo.runtime.common.message that return types with arguments of type ControlMessage.Message

Modifier and Type	Method	Description
MessageSender<ControlMessage.Message>	PersistentConnectionToMasterMap.getMessageSender(java.lang.String listenerId)	Get the message sender corresponding to the given listener ID.
java.util.concurrent.CompletableFuture<ControlMessage.Message>	FailedMessageSender.request(ControlMessage.Message message)

Methods in org.apache.nemo.runtime.common.message with parameters of type ControlMessage.Message

Modifier and Type	Method	Description
java.util.concurrent.CompletableFuture<ControlMessage.Message>	FailedMessageSender.request(ControlMessage.Message message)
void	FailedMessageSender.send(ControlMessage.Message message)

Uses of ControlMessage.Message in org.apache.nemo.runtime.master

Methods in org.apache.nemo.runtime.master with parameters of type ControlMessage.Message

Modifier and Type	Method	Description
void	BlockManagerMaster.BlockManagerMasterControlMessageReceiver.onMessage(ControlMessage.Message message)
void	PipeManagerMaster.PipeManagerMasterControlMessageReceiver.onMessage(ControlMessage.Message message)
void	RuntimeMaster.MasterControlMessageReceiver.onMessage(ControlMessage.Message message)
void	BlockManagerMaster.BlockManagerMasterControlMessageReceiver.onMessageWithContext(ControlMessage.Message message, MessageContext messageContext)
void	PipeManagerMaster.PipeManagerMasterControlMessageReceiver.onMessageWithContext(ControlMessage.Message message, MessageContext messageContext)
void	RuntimeMaster.MasterControlMessageReceiver.onMessageWithContext(ControlMessage.Message message, MessageContext messageContext)

Uses of ControlMessage.Message in org.apache.nemo.runtime.master.resource

Methods in org.apache.nemo.runtime.master.resource with parameters of type ControlMessage.Message

Modifier and Type	Method	Description
void	DefaultExecutorRepresenter.sendControlMessage(ControlMessage.Message message)	Sends control message to the executor.
void	ExecutorRepresenter.sendControlMessage(ControlMessage.Message message)	Sends control message to the executor.

Constructor parameters in org.apache.nemo.runtime.master.resource with type arguments of type ControlMessage.Message

Constructor	Description
DefaultExecutorRepresenter(java.lang.String executorId, ResourceSpecification resourceSpecification, MessageSender<ControlMessage.Message> messageSender, org.apache.reef.driver.context.ActiveContext activeContext, java.util.concurrent.ExecutorService serializationExecutorService, java.lang.String nodeName)	Creates a reference to the specified executor.