Class ControlMessage.Message
- java.lang.Object
-
- com.google.protobuf.AbstractMessageLite
-
- com.google.protobuf.AbstractMessage
-
- com.google.protobuf.GeneratedMessageV3
-
- org.apache.nemo.runtime.common.comm.ControlMessage.Message
-
- All Implemented Interfaces:
com.google.protobuf.Message
,com.google.protobuf.MessageLite
,com.google.protobuf.MessageLiteOrBuilder
,com.google.protobuf.MessageOrBuilder
,java.io.Serializable
,ControlMessage.MessageOrBuilder
- Enclosing class:
- ControlMessage
public static final class ControlMessage.Message extends com.google.protobuf.GeneratedMessageV3 implements ControlMessage.MessageOrBuilder
Protobuf typeprotobuf.Message
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ControlMessage.Message.Builder
Protobuf typeprotobuf.Message
-
Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessageV3
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable, com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter
-
-
Field Summary
Fields Modifier and Type Field Description static int
BLOCKLOCATIONINFOMSG_FIELD_NUMBER
static int
BLOCKSTATECHANGEDMSG_FIELD_NUMBER
static int
BROADCASTVARIABLEMSG_FIELD_NUMBER
static int
CONTAINERFAILEDMSG_FIELD_NUMBER
static int
DATACOLLECTED_FIELD_NUMBER
static int
EXECUTORFAILEDMSG_FIELD_NUMBER
static int
ID_FIELD_NUMBER
static int
LISTENERID_FIELD_NUMBER
static int
METRICMSG_FIELD_NUMBER
static com.google.protobuf.Parser<ControlMessage.Message>
PARSER
Deprecated.static int
PIPEINITMSG_FIELD_NUMBER
static int
PIPELOCINFOMSG_FIELD_NUMBER
static int
REQUESTBLOCKLOCATIONMSG_FIELD_NUMBER
static int
REQUESTBROADCASTVARIABLEMSG_FIELD_NUMBER
static int
REQUESTPIPELOCMSG_FIELD_NUMBER
static int
RUNTIMEPASSMESSAGEMSG_FIELD_NUMBER
static int
SCHEDULETASKMSG_FIELD_NUMBER
static int
TASKSTATECHANGEDMSG_FIELD_NUMBER
static int
TYPE_FIELD_NUMBER
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(java.lang.Object obj)
ControlMessage.BlockLocationInfoMsg
getBlockLocationInfoMsg()
optional .protobuf.BlockLocationInfoMsg blockLocationInfoMsg = 9;
ControlMessage.BlockLocationInfoMsgOrBuilder
getBlockLocationInfoMsgOrBuilder()
optional .protobuf.BlockLocationInfoMsg blockLocationInfoMsg = 9;
ControlMessage.BlockStateChangedMsg
getBlockStateChangedMsg()
optional .protobuf.BlockStateChangedMsg blockStateChangedMsg = 6;
ControlMessage.BlockStateChangedMsgOrBuilder
getBlockStateChangedMsgOrBuilder()
optional .protobuf.BlockStateChangedMsg blockStateChangedMsg = 6;
ControlMessage.InMasterBroadcastVariableMessage
getBroadcastVariableMsg()
optional .protobuf.InMasterBroadcastVariableMessage broadcastVariableMsg = 15;
ControlMessage.InMasterBroadcastVariableMessageOrBuilder
getBroadcastVariableMsgOrBuilder()
optional .protobuf.InMasterBroadcastVariableMessage broadcastVariableMsg = 15;
ControlMessage.ContainerFailedMsg
getContainerFailedMsg()
optional .protobuf.ContainerFailedMsg containerFailedMsg = 11;
ControlMessage.ContainerFailedMsgOrBuilder
getContainerFailedMsgOrBuilder()
optional .protobuf.ContainerFailedMsg containerFailedMsg = 11;
ControlMessage.DataCollectMessage
getDataCollected()
optional .protobuf.DataCollectMessage dataCollected = 13;
ControlMessage.DataCollectMessageOrBuilder
getDataCollectedOrBuilder()
optional .protobuf.DataCollectMessage dataCollected = 13;
static ControlMessage.Message
getDefaultInstance()
ControlMessage.Message
getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor
getDescriptor()
ControlMessage.ExecutorFailedMsg
getExecutorFailedMsg()
optional .protobuf.ExecutorFailedMsg executorFailedMsg = 10;
ControlMessage.ExecutorFailedMsgOrBuilder
getExecutorFailedMsgOrBuilder()
optional .protobuf.ExecutorFailedMsg executorFailedMsg = 10;
long
getId()
required int64 id = 2;
java.lang.String
getListenerId()
The id of the message listener (handler).com.google.protobuf.ByteString
getListenerIdBytes()
The id of the message listener (handler).ControlMessage.MetricMsg
getMetricMsg()
optional .protobuf.MetricMsg metricMsg = 12;
ControlMessage.MetricMsgOrBuilder
getMetricMsgOrBuilder()
optional .protobuf.MetricMsg metricMsg = 12;
com.google.protobuf.Parser<ControlMessage.Message>
getParserForType()
ControlMessage.PipeInitMessage
getPipeInitMsg()
optional .protobuf.PipeInitMessage pipeInitMsg = 16;
ControlMessage.PipeInitMessageOrBuilder
getPipeInitMsgOrBuilder()
optional .protobuf.PipeInitMessage pipeInitMsg = 16;
ControlMessage.PipeLocationInfoMessage
getPipeLocInfoMsg()
optional .protobuf.PipeLocationInfoMessage pipeLocInfoMsg = 18;
ControlMessage.PipeLocationInfoMessageOrBuilder
getPipeLocInfoMsgOrBuilder()
optional .protobuf.PipeLocationInfoMessage pipeLocInfoMsg = 18;
ControlMessage.RequestBlockLocationMsg
getRequestBlockLocationMsg()
optional .protobuf.RequestBlockLocationMsg requestBlockLocationMsg = 8;
ControlMessage.RequestBlockLocationMsgOrBuilder
getRequestBlockLocationMsgOrBuilder()
optional .protobuf.RequestBlockLocationMsg requestBlockLocationMsg = 8;
ControlMessage.RequestBroadcastVariableMessage
getRequestbroadcastVariableMsg()
optional .protobuf.RequestBroadcastVariableMessage requestbroadcastVariableMsg = 14;
ControlMessage.RequestBroadcastVariableMessageOrBuilder
getRequestbroadcastVariableMsgOrBuilder()
optional .protobuf.RequestBroadcastVariableMessage requestbroadcastVariableMsg = 14;
ControlMessage.RequestPipeLocationMessage
getRequestPipeLocMsg()
optional .protobuf.RequestPipeLocationMessage requestPipeLocMsg = 17;
ControlMessage.RequestPipeLocationMessageOrBuilder
getRequestPipeLocMsgOrBuilder()
optional .protobuf.RequestPipeLocationMessage requestPipeLocMsg = 17;
ControlMessage.RunTimePassMessageMsg
getRunTimePassMessageMsg()
optional .protobuf.RunTimePassMessageMsg runTimePassMessageMsg = 7;
ControlMessage.RunTimePassMessageMsgOrBuilder
getRunTimePassMessageMsgOrBuilder()
optional .protobuf.RunTimePassMessageMsg runTimePassMessageMsg = 7;
ControlMessage.ScheduleTaskMsg
getScheduleTaskMsg()
optional .protobuf.ScheduleTaskMsg scheduleTaskMsg = 5;
ControlMessage.ScheduleTaskMsgOrBuilder
getScheduleTaskMsgOrBuilder()
optional .protobuf.ScheduleTaskMsg scheduleTaskMsg = 5;
int
getSerializedSize()
ControlMessage.TaskStateChangedMsg
getTaskStateChangedMsg()
optional .protobuf.TaskStateChangedMsg taskStateChangedMsg = 4;
ControlMessage.TaskStateChangedMsgOrBuilder
getTaskStateChangedMsgOrBuilder()
optional .protobuf.TaskStateChangedMsg taskStateChangedMsg = 4;
ControlMessage.MessageType
getType()
required .protobuf.MessageType type = 1;
com.google.protobuf.UnknownFieldSet
getUnknownFields()
boolean
hasBlockLocationInfoMsg()
optional .protobuf.BlockLocationInfoMsg blockLocationInfoMsg = 9;
boolean
hasBlockStateChangedMsg()
optional .protobuf.BlockStateChangedMsg blockStateChangedMsg = 6;
boolean
hasBroadcastVariableMsg()
optional .protobuf.InMasterBroadcastVariableMessage broadcastVariableMsg = 15;
boolean
hasContainerFailedMsg()
optional .protobuf.ContainerFailedMsg containerFailedMsg = 11;
boolean
hasDataCollected()
optional .protobuf.DataCollectMessage dataCollected = 13;
boolean
hasExecutorFailedMsg()
optional .protobuf.ExecutorFailedMsg executorFailedMsg = 10;
int
hashCode()
boolean
hasId()
required int64 id = 2;
boolean
hasListenerId()
The id of the message listener (handler).boolean
hasMetricMsg()
optional .protobuf.MetricMsg metricMsg = 12;
boolean
hasPipeInitMsg()
optional .protobuf.PipeInitMessage pipeInitMsg = 16;
boolean
hasPipeLocInfoMsg()
optional .protobuf.PipeLocationInfoMessage pipeLocInfoMsg = 18;
boolean
hasRequestBlockLocationMsg()
optional .protobuf.RequestBlockLocationMsg requestBlockLocationMsg = 8;
boolean
hasRequestbroadcastVariableMsg()
optional .protobuf.RequestBroadcastVariableMessage requestbroadcastVariableMsg = 14;
boolean
hasRequestPipeLocMsg()
optional .protobuf.RequestPipeLocationMessage requestPipeLocMsg = 17;
boolean
hasRunTimePassMessageMsg()
optional .protobuf.RunTimePassMessageMsg runTimePassMessageMsg = 7;
boolean
hasScheduleTaskMsg()
optional .protobuf.ScheduleTaskMsg scheduleTaskMsg = 5;
boolean
hasTaskStateChangedMsg()
optional .protobuf.TaskStateChangedMsg taskStateChangedMsg = 4;
boolean
hasType()
required .protobuf.MessageType type = 1;
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
internalGetFieldAccessorTable()
boolean
isInitialized()
static ControlMessage.Message.Builder
newBuilder()
static ControlMessage.Message.Builder
newBuilder(ControlMessage.Message prototype)
ControlMessage.Message.Builder
newBuilderForType()
protected ControlMessage.Message.Builder
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
protected java.lang.Object
newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
static ControlMessage.Message
parseDelimitedFrom(java.io.InputStream input)
static ControlMessage.Message
parseDelimitedFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ControlMessage.Message
parseFrom(byte[] data)
static ControlMessage.Message
parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ControlMessage.Message
parseFrom(com.google.protobuf.ByteString data)
static ControlMessage.Message
parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ControlMessage.Message
parseFrom(com.google.protobuf.CodedInputStream input)
static ControlMessage.Message
parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ControlMessage.Message
parseFrom(java.io.InputStream input)
static ControlMessage.Message
parseFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static ControlMessage.Message
parseFrom(java.nio.ByteBuffer data)
static ControlMessage.Message
parseFrom(java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static com.google.protobuf.Parser<ControlMessage.Message>
parser()
ControlMessage.Message.Builder
toBuilder()
void
writeTo(com.google.protobuf.CodedOutputStream output)
-
Methods inherited from class com.google.protobuf.GeneratedMessageV3
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof, internalGetMapField, isStringEmpty, makeExtensionsImmutable, mergeFromAndMakeImmutableInternal, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newIntList, newLongList, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag
-
Methods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
-
Methods inherited from class com.google.protobuf.AbstractMessageLite
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
TYPE_FIELD_NUMBER
public static final int TYPE_FIELD_NUMBER
- See Also:
- Constant Field Values
-
ID_FIELD_NUMBER
public static final int ID_FIELD_NUMBER
- See Also:
- Constant Field Values
-
LISTENERID_FIELD_NUMBER
public static final int LISTENERID_FIELD_NUMBER
- See Also:
- Constant Field Values
-
TASKSTATECHANGEDMSG_FIELD_NUMBER
public static final int TASKSTATECHANGEDMSG_FIELD_NUMBER
- See Also:
- Constant Field Values
-
SCHEDULETASKMSG_FIELD_NUMBER
public static final int SCHEDULETASKMSG_FIELD_NUMBER
- See Also:
- Constant Field Values
-
BLOCKSTATECHANGEDMSG_FIELD_NUMBER
public static final int BLOCKSTATECHANGEDMSG_FIELD_NUMBER
- See Also:
- Constant Field Values
-
RUNTIMEPASSMESSAGEMSG_FIELD_NUMBER
public static final int RUNTIMEPASSMESSAGEMSG_FIELD_NUMBER
- See Also:
- Constant Field Values
-
REQUESTBLOCKLOCATIONMSG_FIELD_NUMBER
public static final int REQUESTBLOCKLOCATIONMSG_FIELD_NUMBER
- See Also:
- Constant Field Values
-
BLOCKLOCATIONINFOMSG_FIELD_NUMBER
public static final int BLOCKLOCATIONINFOMSG_FIELD_NUMBER
- See Also:
- Constant Field Values
-
EXECUTORFAILEDMSG_FIELD_NUMBER
public static final int EXECUTORFAILEDMSG_FIELD_NUMBER
- See Also:
- Constant Field Values
-
CONTAINERFAILEDMSG_FIELD_NUMBER
public static final int CONTAINERFAILEDMSG_FIELD_NUMBER
- See Also:
- Constant Field Values
-
METRICMSG_FIELD_NUMBER
public static final int METRICMSG_FIELD_NUMBER
- See Also:
- Constant Field Values
-
DATACOLLECTED_FIELD_NUMBER
public static final int DATACOLLECTED_FIELD_NUMBER
- See Also:
- Constant Field Values
-
REQUESTBROADCASTVARIABLEMSG_FIELD_NUMBER
public static final int REQUESTBROADCASTVARIABLEMSG_FIELD_NUMBER
- See Also:
- Constant Field Values
-
BROADCASTVARIABLEMSG_FIELD_NUMBER
public static final int BROADCASTVARIABLEMSG_FIELD_NUMBER
- See Also:
- Constant Field Values
-
PIPEINITMSG_FIELD_NUMBER
public static final int PIPEINITMSG_FIELD_NUMBER
- See Also:
- Constant Field Values
-
REQUESTPIPELOCMSG_FIELD_NUMBER
public static final int REQUESTPIPELOCMSG_FIELD_NUMBER
- See Also:
- Constant Field Values
-
PIPELOCINFOMSG_FIELD_NUMBER
public static final int PIPELOCINFOMSG_FIELD_NUMBER
- See Also:
- Constant Field Values
-
PARSER
@Deprecated public static final com.google.protobuf.Parser<ControlMessage.Message> PARSER
Deprecated.
-
-
Method Detail
-
newInstance
protected java.lang.Object newInstance(com.google.protobuf.GeneratedMessageV3.UnusedPrivateParameter unused)
- Overrides:
newInstance
in classcom.google.protobuf.GeneratedMessageV3
-
getUnknownFields
public final com.google.protobuf.UnknownFieldSet getUnknownFields()
- Specified by:
getUnknownFields
in interfacecom.google.protobuf.MessageOrBuilder
- Overrides:
getUnknownFields
in classcom.google.protobuf.GeneratedMessageV3
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
-
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
- Specified by:
internalGetFieldAccessorTable
in classcom.google.protobuf.GeneratedMessageV3
-
hasType
public boolean hasType()
required .protobuf.MessageType type = 1;
- Specified by:
hasType
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the type field is set.
-
getType
public ControlMessage.MessageType getType()
required .protobuf.MessageType type = 1;
- Specified by:
getType
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The type.
-
hasId
public boolean hasId()
required int64 id = 2;
- Specified by:
hasId
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the id field is set.
-
getId
public long getId()
required int64 id = 2;
- Specified by:
getId
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The id.
-
hasListenerId
public boolean hasListenerId()
The id of the message listener (handler).
required string listenerId = 3;
- Specified by:
hasListenerId
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the listenerId field is set.
-
getListenerId
public java.lang.String getListenerId()
The id of the message listener (handler).
required string listenerId = 3;
- Specified by:
getListenerId
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The listenerId.
-
getListenerIdBytes
public com.google.protobuf.ByteString getListenerIdBytes()
The id of the message listener (handler).
required string listenerId = 3;
- Specified by:
getListenerIdBytes
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The bytes for listenerId.
-
hasTaskStateChangedMsg
public boolean hasTaskStateChangedMsg()
optional .protobuf.TaskStateChangedMsg taskStateChangedMsg = 4;
- Specified by:
hasTaskStateChangedMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the taskStateChangedMsg field is set.
-
getTaskStateChangedMsg
public ControlMessage.TaskStateChangedMsg getTaskStateChangedMsg()
optional .protobuf.TaskStateChangedMsg taskStateChangedMsg = 4;
- Specified by:
getTaskStateChangedMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The taskStateChangedMsg.
-
getTaskStateChangedMsgOrBuilder
public ControlMessage.TaskStateChangedMsgOrBuilder getTaskStateChangedMsgOrBuilder()
optional .protobuf.TaskStateChangedMsg taskStateChangedMsg = 4;
- Specified by:
getTaskStateChangedMsgOrBuilder
in interfaceControlMessage.MessageOrBuilder
-
hasScheduleTaskMsg
public boolean hasScheduleTaskMsg()
optional .protobuf.ScheduleTaskMsg scheduleTaskMsg = 5;
- Specified by:
hasScheduleTaskMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the scheduleTaskMsg field is set.
-
getScheduleTaskMsg
public ControlMessage.ScheduleTaskMsg getScheduleTaskMsg()
optional .protobuf.ScheduleTaskMsg scheduleTaskMsg = 5;
- Specified by:
getScheduleTaskMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The scheduleTaskMsg.
-
getScheduleTaskMsgOrBuilder
public ControlMessage.ScheduleTaskMsgOrBuilder getScheduleTaskMsgOrBuilder()
optional .protobuf.ScheduleTaskMsg scheduleTaskMsg = 5;
- Specified by:
getScheduleTaskMsgOrBuilder
in interfaceControlMessage.MessageOrBuilder
-
hasBlockStateChangedMsg
public boolean hasBlockStateChangedMsg()
optional .protobuf.BlockStateChangedMsg blockStateChangedMsg = 6;
- Specified by:
hasBlockStateChangedMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the blockStateChangedMsg field is set.
-
getBlockStateChangedMsg
public ControlMessage.BlockStateChangedMsg getBlockStateChangedMsg()
optional .protobuf.BlockStateChangedMsg blockStateChangedMsg = 6;
- Specified by:
getBlockStateChangedMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The blockStateChangedMsg.
-
getBlockStateChangedMsgOrBuilder
public ControlMessage.BlockStateChangedMsgOrBuilder getBlockStateChangedMsgOrBuilder()
optional .protobuf.BlockStateChangedMsg blockStateChangedMsg = 6;
- Specified by:
getBlockStateChangedMsgOrBuilder
in interfaceControlMessage.MessageOrBuilder
-
hasRunTimePassMessageMsg
public boolean hasRunTimePassMessageMsg()
optional .protobuf.RunTimePassMessageMsg runTimePassMessageMsg = 7;
- Specified by:
hasRunTimePassMessageMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the runTimePassMessageMsg field is set.
-
getRunTimePassMessageMsg
public ControlMessage.RunTimePassMessageMsg getRunTimePassMessageMsg()
optional .protobuf.RunTimePassMessageMsg runTimePassMessageMsg = 7;
- Specified by:
getRunTimePassMessageMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The runTimePassMessageMsg.
-
getRunTimePassMessageMsgOrBuilder
public ControlMessage.RunTimePassMessageMsgOrBuilder getRunTimePassMessageMsgOrBuilder()
optional .protobuf.RunTimePassMessageMsg runTimePassMessageMsg = 7;
- Specified by:
getRunTimePassMessageMsgOrBuilder
in interfaceControlMessage.MessageOrBuilder
-
hasRequestBlockLocationMsg
public boolean hasRequestBlockLocationMsg()
optional .protobuf.RequestBlockLocationMsg requestBlockLocationMsg = 8;
- Specified by:
hasRequestBlockLocationMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the requestBlockLocationMsg field is set.
-
getRequestBlockLocationMsg
public ControlMessage.RequestBlockLocationMsg getRequestBlockLocationMsg()
optional .protobuf.RequestBlockLocationMsg requestBlockLocationMsg = 8;
- Specified by:
getRequestBlockLocationMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The requestBlockLocationMsg.
-
getRequestBlockLocationMsgOrBuilder
public ControlMessage.RequestBlockLocationMsgOrBuilder getRequestBlockLocationMsgOrBuilder()
optional .protobuf.RequestBlockLocationMsg requestBlockLocationMsg = 8;
- Specified by:
getRequestBlockLocationMsgOrBuilder
in interfaceControlMessage.MessageOrBuilder
-
hasBlockLocationInfoMsg
public boolean hasBlockLocationInfoMsg()
optional .protobuf.BlockLocationInfoMsg blockLocationInfoMsg = 9;
- Specified by:
hasBlockLocationInfoMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the blockLocationInfoMsg field is set.
-
getBlockLocationInfoMsg
public ControlMessage.BlockLocationInfoMsg getBlockLocationInfoMsg()
optional .protobuf.BlockLocationInfoMsg blockLocationInfoMsg = 9;
- Specified by:
getBlockLocationInfoMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The blockLocationInfoMsg.
-
getBlockLocationInfoMsgOrBuilder
public ControlMessage.BlockLocationInfoMsgOrBuilder getBlockLocationInfoMsgOrBuilder()
optional .protobuf.BlockLocationInfoMsg blockLocationInfoMsg = 9;
- Specified by:
getBlockLocationInfoMsgOrBuilder
in interfaceControlMessage.MessageOrBuilder
-
hasExecutorFailedMsg
public boolean hasExecutorFailedMsg()
optional .protobuf.ExecutorFailedMsg executorFailedMsg = 10;
- Specified by:
hasExecutorFailedMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the executorFailedMsg field is set.
-
getExecutorFailedMsg
public ControlMessage.ExecutorFailedMsg getExecutorFailedMsg()
optional .protobuf.ExecutorFailedMsg executorFailedMsg = 10;
- Specified by:
getExecutorFailedMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The executorFailedMsg.
-
getExecutorFailedMsgOrBuilder
public ControlMessage.ExecutorFailedMsgOrBuilder getExecutorFailedMsgOrBuilder()
optional .protobuf.ExecutorFailedMsg executorFailedMsg = 10;
- Specified by:
getExecutorFailedMsgOrBuilder
in interfaceControlMessage.MessageOrBuilder
-
hasContainerFailedMsg
public boolean hasContainerFailedMsg()
optional .protobuf.ContainerFailedMsg containerFailedMsg = 11;
- Specified by:
hasContainerFailedMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the containerFailedMsg field is set.
-
getContainerFailedMsg
public ControlMessage.ContainerFailedMsg getContainerFailedMsg()
optional .protobuf.ContainerFailedMsg containerFailedMsg = 11;
- Specified by:
getContainerFailedMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The containerFailedMsg.
-
getContainerFailedMsgOrBuilder
public ControlMessage.ContainerFailedMsgOrBuilder getContainerFailedMsgOrBuilder()
optional .protobuf.ContainerFailedMsg containerFailedMsg = 11;
- Specified by:
getContainerFailedMsgOrBuilder
in interfaceControlMessage.MessageOrBuilder
-
hasMetricMsg
public boolean hasMetricMsg()
optional .protobuf.MetricMsg metricMsg = 12;
- Specified by:
hasMetricMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the metricMsg field is set.
-
getMetricMsg
public ControlMessage.MetricMsg getMetricMsg()
optional .protobuf.MetricMsg metricMsg = 12;
- Specified by:
getMetricMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The metricMsg.
-
getMetricMsgOrBuilder
public ControlMessage.MetricMsgOrBuilder getMetricMsgOrBuilder()
optional .protobuf.MetricMsg metricMsg = 12;
- Specified by:
getMetricMsgOrBuilder
in interfaceControlMessage.MessageOrBuilder
-
hasDataCollected
public boolean hasDataCollected()
optional .protobuf.DataCollectMessage dataCollected = 13;
- Specified by:
hasDataCollected
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the dataCollected field is set.
-
getDataCollected
public ControlMessage.DataCollectMessage getDataCollected()
optional .protobuf.DataCollectMessage dataCollected = 13;
- Specified by:
getDataCollected
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The dataCollected.
-
getDataCollectedOrBuilder
public ControlMessage.DataCollectMessageOrBuilder getDataCollectedOrBuilder()
optional .protobuf.DataCollectMessage dataCollected = 13;
- Specified by:
getDataCollectedOrBuilder
in interfaceControlMessage.MessageOrBuilder
-
hasRequestbroadcastVariableMsg
public boolean hasRequestbroadcastVariableMsg()
optional .protobuf.RequestBroadcastVariableMessage requestbroadcastVariableMsg = 14;
- Specified by:
hasRequestbroadcastVariableMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the requestbroadcastVariableMsg field is set.
-
getRequestbroadcastVariableMsg
public ControlMessage.RequestBroadcastVariableMessage getRequestbroadcastVariableMsg()
optional .protobuf.RequestBroadcastVariableMessage requestbroadcastVariableMsg = 14;
- Specified by:
getRequestbroadcastVariableMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The requestbroadcastVariableMsg.
-
getRequestbroadcastVariableMsgOrBuilder
public ControlMessage.RequestBroadcastVariableMessageOrBuilder getRequestbroadcastVariableMsgOrBuilder()
optional .protobuf.RequestBroadcastVariableMessage requestbroadcastVariableMsg = 14;
- Specified by:
getRequestbroadcastVariableMsgOrBuilder
in interfaceControlMessage.MessageOrBuilder
-
hasBroadcastVariableMsg
public boolean hasBroadcastVariableMsg()
optional .protobuf.InMasterBroadcastVariableMessage broadcastVariableMsg = 15;
- Specified by:
hasBroadcastVariableMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the broadcastVariableMsg field is set.
-
getBroadcastVariableMsg
public ControlMessage.InMasterBroadcastVariableMessage getBroadcastVariableMsg()
optional .protobuf.InMasterBroadcastVariableMessage broadcastVariableMsg = 15;
- Specified by:
getBroadcastVariableMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The broadcastVariableMsg.
-
getBroadcastVariableMsgOrBuilder
public ControlMessage.InMasterBroadcastVariableMessageOrBuilder getBroadcastVariableMsgOrBuilder()
optional .protobuf.InMasterBroadcastVariableMessage broadcastVariableMsg = 15;
- Specified by:
getBroadcastVariableMsgOrBuilder
in interfaceControlMessage.MessageOrBuilder
-
hasPipeInitMsg
public boolean hasPipeInitMsg()
optional .protobuf.PipeInitMessage pipeInitMsg = 16;
- Specified by:
hasPipeInitMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the pipeInitMsg field is set.
-
getPipeInitMsg
public ControlMessage.PipeInitMessage getPipeInitMsg()
optional .protobuf.PipeInitMessage pipeInitMsg = 16;
- Specified by:
getPipeInitMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The pipeInitMsg.
-
getPipeInitMsgOrBuilder
public ControlMessage.PipeInitMessageOrBuilder getPipeInitMsgOrBuilder()
optional .protobuf.PipeInitMessage pipeInitMsg = 16;
- Specified by:
getPipeInitMsgOrBuilder
in interfaceControlMessage.MessageOrBuilder
-
hasRequestPipeLocMsg
public boolean hasRequestPipeLocMsg()
optional .protobuf.RequestPipeLocationMessage requestPipeLocMsg = 17;
- Specified by:
hasRequestPipeLocMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the requestPipeLocMsg field is set.
-
getRequestPipeLocMsg
public ControlMessage.RequestPipeLocationMessage getRequestPipeLocMsg()
optional .protobuf.RequestPipeLocationMessage requestPipeLocMsg = 17;
- Specified by:
getRequestPipeLocMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The requestPipeLocMsg.
-
getRequestPipeLocMsgOrBuilder
public ControlMessage.RequestPipeLocationMessageOrBuilder getRequestPipeLocMsgOrBuilder()
optional .protobuf.RequestPipeLocationMessage requestPipeLocMsg = 17;
- Specified by:
getRequestPipeLocMsgOrBuilder
in interfaceControlMessage.MessageOrBuilder
-
hasPipeLocInfoMsg
public boolean hasPipeLocInfoMsg()
optional .protobuf.PipeLocationInfoMessage pipeLocInfoMsg = 18;
- Specified by:
hasPipeLocInfoMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- Whether the pipeLocInfoMsg field is set.
-
getPipeLocInfoMsg
public ControlMessage.PipeLocationInfoMessage getPipeLocInfoMsg()
optional .protobuf.PipeLocationInfoMessage pipeLocInfoMsg = 18;
- Specified by:
getPipeLocInfoMsg
in interfaceControlMessage.MessageOrBuilder
- Returns:
- The pipeLocInfoMsg.
-
getPipeLocInfoMsgOrBuilder
public ControlMessage.PipeLocationInfoMessageOrBuilder getPipeLocInfoMsgOrBuilder()
optional .protobuf.PipeLocationInfoMessage pipeLocInfoMsg = 18;
- Specified by:
getPipeLocInfoMsgOrBuilder
in interfaceControlMessage.MessageOrBuilder
-
isInitialized
public final boolean isInitialized()
- Specified by:
isInitialized
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Overrides:
isInitialized
in classcom.google.protobuf.GeneratedMessageV3
-
writeTo
public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException
- Specified by:
writeTo
in interfacecom.google.protobuf.MessageLite
- Overrides:
writeTo
in classcom.google.protobuf.GeneratedMessageV3
- Throws:
java.io.IOException
-
getSerializedSize
public int getSerializedSize()
- Specified by:
getSerializedSize
in interfacecom.google.protobuf.MessageLite
- Overrides:
getSerializedSize
in classcom.google.protobuf.GeneratedMessageV3
-
equals
public boolean equals(java.lang.Object obj)
- Specified by:
equals
in interfacecom.google.protobuf.Message
- Overrides:
equals
in classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()
- Specified by:
hashCode
in interfacecom.google.protobuf.Message
- Overrides:
hashCode
in classcom.google.protobuf.AbstractMessage
-
parseFrom
public static ControlMessage.Message parseFrom(java.nio.ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ControlMessage.Message parseFrom(java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ControlMessage.Message parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ControlMessage.Message parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ControlMessage.Message parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ControlMessage.Message parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
- Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static ControlMessage.Message parseFrom(java.io.InputStream input) throws java.io.IOException
- Throws:
java.io.IOException
-
parseFrom
public static ControlMessage.Message parseFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
- Throws:
java.io.IOException
-
parseDelimitedFrom
public static ControlMessage.Message parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException
- Throws:
java.io.IOException
-
parseDelimitedFrom
public static ControlMessage.Message parseDelimitedFrom(java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
- Throws:
java.io.IOException
-
parseFrom
public static ControlMessage.Message parseFrom(com.google.protobuf.CodedInputStream input) throws java.io.IOException
- Throws:
java.io.IOException
-
parseFrom
public static ControlMessage.Message parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException
- Throws:
java.io.IOException
-
newBuilderForType
public ControlMessage.Message.Builder newBuilderForType()
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.Message
- Specified by:
newBuilderForType
in interfacecom.google.protobuf.MessageLite
-
newBuilder
public static ControlMessage.Message.Builder newBuilder()
-
newBuilder
public static ControlMessage.Message.Builder newBuilder(ControlMessage.Message prototype)
-
toBuilder
public ControlMessage.Message.Builder toBuilder()
- Specified by:
toBuilder
in interfacecom.google.protobuf.Message
- Specified by:
toBuilder
in interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected ControlMessage.Message.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
- Specified by:
newBuilderForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstance
public static ControlMessage.Message getDefaultInstance()
-
parser
public static com.google.protobuf.Parser<ControlMessage.Message> parser()
-
getParserForType
public com.google.protobuf.Parser<ControlMessage.Message> getParserForType()
- Specified by:
getParserForType
in interfacecom.google.protobuf.Message
- Specified by:
getParserForType
in interfacecom.google.protobuf.MessageLite
- Overrides:
getParserForType
in classcom.google.protobuf.GeneratedMessageV3
-
getDefaultInstanceForType
public ControlMessage.Message getDefaultInstanceForType()
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageLiteOrBuilder
- Specified by:
getDefaultInstanceForType
in interfacecom.google.protobuf.MessageOrBuilder
-
-