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

Packages that use ControlMessage.Message.Builder

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

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

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

Modifier and Type	Method	Description
ControlMessage.Message.Builder	ControlMessage.Message.Builder.addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value)
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clear()
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearBlockLocationInfoMsg()	optional .protobuf.BlockLocationInfoMsg blockLocationInfoMsg = 9;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearBlockStateChangedMsg()	optional .protobuf.BlockStateChangedMsg blockStateChangedMsg = 6;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearBroadcastVariableMsg()	optional .protobuf.InMasterBroadcastVariableMessage broadcastVariableMsg = 15;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearContainerFailedMsg()	optional .protobuf.ContainerFailedMsg containerFailedMsg = 11;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearDataCollected()	optional .protobuf.DataCollectMessage dataCollected = 13;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearExecutorFailedMsg()	optional .protobuf.ExecutorFailedMsg executorFailedMsg = 10;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearId()	required int64 id = 2;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearListenerId()	The id of the message listener (handler).
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearMetricMsg()	optional .protobuf.MetricMsg metricMsg = 12;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearPipeInitMsg()	optional .protobuf.PipeInitMessage pipeInitMsg = 16;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearPipeLocInfoMsg()	optional .protobuf.PipeLocationInfoMessage pipeLocInfoMsg = 18;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearRequestBlockLocationMsg()	optional .protobuf.RequestBlockLocationMsg requestBlockLocationMsg = 8;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearRequestbroadcastVariableMsg()	optional .protobuf.RequestBroadcastVariableMessage requestbroadcastVariableMsg = 14;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearRequestPipeLocMsg()	optional .protobuf.RequestPipeLocationMessage requestPipeLocMsg = 17;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearRunTimePassMessageMsg()	optional .protobuf.RunTimePassMessageMsg runTimePassMessageMsg = 7;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearScheduleTaskMsg()	optional .protobuf.ScheduleTaskMsg scheduleTaskMsg = 5;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearTaskStateChangedMsg()	optional .protobuf.TaskStateChangedMsg taskStateChangedMsg = 4;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clearType()	required .protobuf.MessageType type = 1;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.clone()
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeBlockLocationInfoMsg(ControlMessage.BlockLocationInfoMsg value)	optional .protobuf.BlockLocationInfoMsg blockLocationInfoMsg = 9;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeBlockStateChangedMsg(ControlMessage.BlockStateChangedMsg value)	optional .protobuf.BlockStateChangedMsg blockStateChangedMsg = 6;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeBroadcastVariableMsg(ControlMessage.InMasterBroadcastVariableMessage value)	optional .protobuf.InMasterBroadcastVariableMessage broadcastVariableMsg = 15;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeContainerFailedMsg(ControlMessage.ContainerFailedMsg value)	optional .protobuf.ContainerFailedMsg containerFailedMsg = 11;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeDataCollected(ControlMessage.DataCollectMessage value)	optional .protobuf.DataCollectMessage dataCollected = 13;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeExecutorFailedMsg(ControlMessage.ExecutorFailedMsg value)	optional .protobuf.ExecutorFailedMsg executorFailedMsg = 10;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeFrom(com.google.protobuf.Message other)
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeFrom(ControlMessage.Message other)
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeMetricMsg(ControlMessage.MetricMsg value)	optional .protobuf.MetricMsg metricMsg = 12;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergePipeInitMsg(ControlMessage.PipeInitMessage value)	optional .protobuf.PipeInitMessage pipeInitMsg = 16;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergePipeLocInfoMsg(ControlMessage.PipeLocationInfoMessage value)	optional .protobuf.PipeLocationInfoMessage pipeLocInfoMsg = 18;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeRequestBlockLocationMsg(ControlMessage.RequestBlockLocationMsg value)	optional .protobuf.RequestBlockLocationMsg requestBlockLocationMsg = 8;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeRequestbroadcastVariableMsg(ControlMessage.RequestBroadcastVariableMessage value)	optional .protobuf.RequestBroadcastVariableMessage requestbroadcastVariableMsg = 14;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeRequestPipeLocMsg(ControlMessage.RequestPipeLocationMessage value)	optional .protobuf.RequestPipeLocationMessage requestPipeLocMsg = 17;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeRunTimePassMessageMsg(ControlMessage.RunTimePassMessageMsg value)	optional .protobuf.RunTimePassMessageMsg runTimePassMessageMsg = 7;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeScheduleTaskMsg(ControlMessage.ScheduleTaskMsg value)	optional .protobuf.ScheduleTaskMsg scheduleTaskMsg = 5;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeTaskStateChangedMsg(ControlMessage.TaskStateChangedMsg value)	optional .protobuf.TaskStateChangedMsg taskStateChangedMsg = 4;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
static ControlMessage.Message.Builder	ControlMessage.Message.newBuilder()
static ControlMessage.Message.Builder	ControlMessage.Message.newBuilder(ControlMessage.Message prototype)
ControlMessage.Message.Builder	ControlMessage.Message.newBuilderForType()
protected ControlMessage.Message.Builder	ControlMessage.Message.newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setBlockLocationInfoMsg(ControlMessage.BlockLocationInfoMsg value)	optional .protobuf.BlockLocationInfoMsg blockLocationInfoMsg = 9;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setBlockLocationInfoMsg(ControlMessage.BlockLocationInfoMsg.Builder builderForValue)	optional .protobuf.BlockLocationInfoMsg blockLocationInfoMsg = 9;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setBlockStateChangedMsg(ControlMessage.BlockStateChangedMsg value)	optional .protobuf.BlockStateChangedMsg blockStateChangedMsg = 6;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setBlockStateChangedMsg(ControlMessage.BlockStateChangedMsg.Builder builderForValue)	optional .protobuf.BlockStateChangedMsg blockStateChangedMsg = 6;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setBroadcastVariableMsg(ControlMessage.InMasterBroadcastVariableMessage value)	optional .protobuf.InMasterBroadcastVariableMessage broadcastVariableMsg = 15;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setBroadcastVariableMsg(ControlMessage.InMasterBroadcastVariableMessage.Builder builderForValue)	optional .protobuf.InMasterBroadcastVariableMessage broadcastVariableMsg = 15;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setContainerFailedMsg(ControlMessage.ContainerFailedMsg value)	optional .protobuf.ContainerFailedMsg containerFailedMsg = 11;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setContainerFailedMsg(ControlMessage.ContainerFailedMsg.Builder builderForValue)	optional .protobuf.ContainerFailedMsg containerFailedMsg = 11;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setDataCollected(ControlMessage.DataCollectMessage value)	optional .protobuf.DataCollectMessage dataCollected = 13;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setDataCollected(ControlMessage.DataCollectMessage.Builder builderForValue)	optional .protobuf.DataCollectMessage dataCollected = 13;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setExecutorFailedMsg(ControlMessage.ExecutorFailedMsg value)	optional .protobuf.ExecutorFailedMsg executorFailedMsg = 10;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setExecutorFailedMsg(ControlMessage.ExecutorFailedMsg.Builder builderForValue)	optional .protobuf.ExecutorFailedMsg executorFailedMsg = 10;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setField(com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value)
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setId(long value)	required int64 id = 2;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setListenerId(java.lang.String value)	The id of the message listener (handler).
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setListenerIdBytes(com.google.protobuf.ByteString value)	The id of the message listener (handler).
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setMetricMsg(ControlMessage.MetricMsg value)	optional .protobuf.MetricMsg metricMsg = 12;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setMetricMsg(ControlMessage.MetricMsg.Builder builderForValue)	optional .protobuf.MetricMsg metricMsg = 12;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setPipeInitMsg(ControlMessage.PipeInitMessage value)	optional .protobuf.PipeInitMessage pipeInitMsg = 16;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setPipeInitMsg(ControlMessage.PipeInitMessage.Builder builderForValue)	optional .protobuf.PipeInitMessage pipeInitMsg = 16;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setPipeLocInfoMsg(ControlMessage.PipeLocationInfoMessage value)	optional .protobuf.PipeLocationInfoMessage pipeLocInfoMsg = 18;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setPipeLocInfoMsg(ControlMessage.PipeLocationInfoMessage.Builder builderForValue)	optional .protobuf.PipeLocationInfoMessage pipeLocInfoMsg = 18;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value)
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setRequestBlockLocationMsg(ControlMessage.RequestBlockLocationMsg value)	optional .protobuf.RequestBlockLocationMsg requestBlockLocationMsg = 8;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setRequestBlockLocationMsg(ControlMessage.RequestBlockLocationMsg.Builder builderForValue)	optional .protobuf.RequestBlockLocationMsg requestBlockLocationMsg = 8;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setRequestbroadcastVariableMsg(ControlMessage.RequestBroadcastVariableMessage value)	optional .protobuf.RequestBroadcastVariableMessage requestbroadcastVariableMsg = 14;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setRequestbroadcastVariableMsg(ControlMessage.RequestBroadcastVariableMessage.Builder builderForValue)	optional .protobuf.RequestBroadcastVariableMessage requestbroadcastVariableMsg = 14;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setRequestPipeLocMsg(ControlMessage.RequestPipeLocationMessage value)	optional .protobuf.RequestPipeLocationMessage requestPipeLocMsg = 17;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setRequestPipeLocMsg(ControlMessage.RequestPipeLocationMessage.Builder builderForValue)	optional .protobuf.RequestPipeLocationMessage requestPipeLocMsg = 17;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setRunTimePassMessageMsg(ControlMessage.RunTimePassMessageMsg value)	optional .protobuf.RunTimePassMessageMsg runTimePassMessageMsg = 7;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setRunTimePassMessageMsg(ControlMessage.RunTimePassMessageMsg.Builder builderForValue)	optional .protobuf.RunTimePassMessageMsg runTimePassMessageMsg = 7;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setScheduleTaskMsg(ControlMessage.ScheduleTaskMsg value)	optional .protobuf.ScheduleTaskMsg scheduleTaskMsg = 5;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setScheduleTaskMsg(ControlMessage.ScheduleTaskMsg.Builder builderForValue)	optional .protobuf.ScheduleTaskMsg scheduleTaskMsg = 5;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setTaskStateChangedMsg(ControlMessage.TaskStateChangedMsg value)	optional .protobuf.TaskStateChangedMsg taskStateChangedMsg = 4;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setTaskStateChangedMsg(ControlMessage.TaskStateChangedMsg.Builder builderForValue)	optional .protobuf.TaskStateChangedMsg taskStateChangedMsg = 4;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setType(ControlMessage.MessageType value)	required .protobuf.MessageType type = 1;
ControlMessage.Message.Builder	ControlMessage.Message.Builder.setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
ControlMessage.Message.Builder	ControlMessage.Message.toBuilder()