Interface ControlMessage.MessageOrBuilder
-
- All Superinterfaces:
com.google.protobuf.MessageLiteOrBuilder
,com.google.protobuf.MessageOrBuilder
- All Known Implementing Classes:
ControlMessage.Message
,ControlMessage.Message.Builder
- Enclosing class:
- ControlMessage
public static interface ControlMessage.MessageOrBuilder extends com.google.protobuf.MessageOrBuilder
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description 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;
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;
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;
ControlMessage.TaskStateChangedMsg
getTaskStateChangedMsg()
optional .protobuf.TaskStateChangedMsg taskStateChangedMsg = 4;
ControlMessage.TaskStateChangedMsgOrBuilder
getTaskStateChangedMsgOrBuilder()
optional .protobuf.TaskStateChangedMsg taskStateChangedMsg = 4;
ControlMessage.MessageType
getType()
required .protobuf.MessageType type = 1;
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;
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;
-
Methods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getDefaultInstanceForType, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
-
-
-
-
Method Detail
-
hasType
boolean hasType()
required .protobuf.MessageType type = 1;
- Returns:
- Whether the type field is set.
-
getType
ControlMessage.MessageType getType()
required .protobuf.MessageType type = 1;
- Returns:
- The type.
-
hasId
boolean hasId()
required int64 id = 2;
- Returns:
- Whether the id field is set.
-
getId
long getId()
required int64 id = 2;
- Returns:
- The id.
-
hasListenerId
boolean hasListenerId()
The id of the message listener (handler).
required string listenerId = 3;
- Returns:
- Whether the listenerId field is set.
-
getListenerId
java.lang.String getListenerId()
The id of the message listener (handler).
required string listenerId = 3;
- Returns:
- The listenerId.
-
getListenerIdBytes
com.google.protobuf.ByteString getListenerIdBytes()
The id of the message listener (handler).
required string listenerId = 3;
- Returns:
- The bytes for listenerId.
-
hasTaskStateChangedMsg
boolean hasTaskStateChangedMsg()
optional .protobuf.TaskStateChangedMsg taskStateChangedMsg = 4;
- Returns:
- Whether the taskStateChangedMsg field is set.
-
getTaskStateChangedMsg
ControlMessage.TaskStateChangedMsg getTaskStateChangedMsg()
optional .protobuf.TaskStateChangedMsg taskStateChangedMsg = 4;
- Returns:
- The taskStateChangedMsg.
-
getTaskStateChangedMsgOrBuilder
ControlMessage.TaskStateChangedMsgOrBuilder getTaskStateChangedMsgOrBuilder()
optional .protobuf.TaskStateChangedMsg taskStateChangedMsg = 4;
-
hasScheduleTaskMsg
boolean hasScheduleTaskMsg()
optional .protobuf.ScheduleTaskMsg scheduleTaskMsg = 5;
- Returns:
- Whether the scheduleTaskMsg field is set.
-
getScheduleTaskMsg
ControlMessage.ScheduleTaskMsg getScheduleTaskMsg()
optional .protobuf.ScheduleTaskMsg scheduleTaskMsg = 5;
- Returns:
- The scheduleTaskMsg.
-
getScheduleTaskMsgOrBuilder
ControlMessage.ScheduleTaskMsgOrBuilder getScheduleTaskMsgOrBuilder()
optional .protobuf.ScheduleTaskMsg scheduleTaskMsg = 5;
-
hasBlockStateChangedMsg
boolean hasBlockStateChangedMsg()
optional .protobuf.BlockStateChangedMsg blockStateChangedMsg = 6;
- Returns:
- Whether the blockStateChangedMsg field is set.
-
getBlockStateChangedMsg
ControlMessage.BlockStateChangedMsg getBlockStateChangedMsg()
optional .protobuf.BlockStateChangedMsg blockStateChangedMsg = 6;
- Returns:
- The blockStateChangedMsg.
-
getBlockStateChangedMsgOrBuilder
ControlMessage.BlockStateChangedMsgOrBuilder getBlockStateChangedMsgOrBuilder()
optional .protobuf.BlockStateChangedMsg blockStateChangedMsg = 6;
-
hasRunTimePassMessageMsg
boolean hasRunTimePassMessageMsg()
optional .protobuf.RunTimePassMessageMsg runTimePassMessageMsg = 7;
- Returns:
- Whether the runTimePassMessageMsg field is set.
-
getRunTimePassMessageMsg
ControlMessage.RunTimePassMessageMsg getRunTimePassMessageMsg()
optional .protobuf.RunTimePassMessageMsg runTimePassMessageMsg = 7;
- Returns:
- The runTimePassMessageMsg.
-
getRunTimePassMessageMsgOrBuilder
ControlMessage.RunTimePassMessageMsgOrBuilder getRunTimePassMessageMsgOrBuilder()
optional .protobuf.RunTimePassMessageMsg runTimePassMessageMsg = 7;
-
hasRequestBlockLocationMsg
boolean hasRequestBlockLocationMsg()
optional .protobuf.RequestBlockLocationMsg requestBlockLocationMsg = 8;
- Returns:
- Whether the requestBlockLocationMsg field is set.
-
getRequestBlockLocationMsg
ControlMessage.RequestBlockLocationMsg getRequestBlockLocationMsg()
optional .protobuf.RequestBlockLocationMsg requestBlockLocationMsg = 8;
- Returns:
- The requestBlockLocationMsg.
-
getRequestBlockLocationMsgOrBuilder
ControlMessage.RequestBlockLocationMsgOrBuilder getRequestBlockLocationMsgOrBuilder()
optional .protobuf.RequestBlockLocationMsg requestBlockLocationMsg = 8;
-
hasBlockLocationInfoMsg
boolean hasBlockLocationInfoMsg()
optional .protobuf.BlockLocationInfoMsg blockLocationInfoMsg = 9;
- Returns:
- Whether the blockLocationInfoMsg field is set.
-
getBlockLocationInfoMsg
ControlMessage.BlockLocationInfoMsg getBlockLocationInfoMsg()
optional .protobuf.BlockLocationInfoMsg blockLocationInfoMsg = 9;
- Returns:
- The blockLocationInfoMsg.
-
getBlockLocationInfoMsgOrBuilder
ControlMessage.BlockLocationInfoMsgOrBuilder getBlockLocationInfoMsgOrBuilder()
optional .protobuf.BlockLocationInfoMsg blockLocationInfoMsg = 9;
-
hasExecutorFailedMsg
boolean hasExecutorFailedMsg()
optional .protobuf.ExecutorFailedMsg executorFailedMsg = 10;
- Returns:
- Whether the executorFailedMsg field is set.
-
getExecutorFailedMsg
ControlMessage.ExecutorFailedMsg getExecutorFailedMsg()
optional .protobuf.ExecutorFailedMsg executorFailedMsg = 10;
- Returns:
- The executorFailedMsg.
-
getExecutorFailedMsgOrBuilder
ControlMessage.ExecutorFailedMsgOrBuilder getExecutorFailedMsgOrBuilder()
optional .protobuf.ExecutorFailedMsg executorFailedMsg = 10;
-
hasContainerFailedMsg
boolean hasContainerFailedMsg()
optional .protobuf.ContainerFailedMsg containerFailedMsg = 11;
- Returns:
- Whether the containerFailedMsg field is set.
-
getContainerFailedMsg
ControlMessage.ContainerFailedMsg getContainerFailedMsg()
optional .protobuf.ContainerFailedMsg containerFailedMsg = 11;
- Returns:
- The containerFailedMsg.
-
getContainerFailedMsgOrBuilder
ControlMessage.ContainerFailedMsgOrBuilder getContainerFailedMsgOrBuilder()
optional .protobuf.ContainerFailedMsg containerFailedMsg = 11;
-
hasMetricMsg
boolean hasMetricMsg()
optional .protobuf.MetricMsg metricMsg = 12;
- Returns:
- Whether the metricMsg field is set.
-
getMetricMsg
ControlMessage.MetricMsg getMetricMsg()
optional .protobuf.MetricMsg metricMsg = 12;
- Returns:
- The metricMsg.
-
getMetricMsgOrBuilder
ControlMessage.MetricMsgOrBuilder getMetricMsgOrBuilder()
optional .protobuf.MetricMsg metricMsg = 12;
-
hasDataCollected
boolean hasDataCollected()
optional .protobuf.DataCollectMessage dataCollected = 13;
- Returns:
- Whether the dataCollected field is set.
-
getDataCollected
ControlMessage.DataCollectMessage getDataCollected()
optional .protobuf.DataCollectMessage dataCollected = 13;
- Returns:
- The dataCollected.
-
getDataCollectedOrBuilder
ControlMessage.DataCollectMessageOrBuilder getDataCollectedOrBuilder()
optional .protobuf.DataCollectMessage dataCollected = 13;
-
hasRequestbroadcastVariableMsg
boolean hasRequestbroadcastVariableMsg()
optional .protobuf.RequestBroadcastVariableMessage requestbroadcastVariableMsg = 14;
- Returns:
- Whether the requestbroadcastVariableMsg field is set.
-
getRequestbroadcastVariableMsg
ControlMessage.RequestBroadcastVariableMessage getRequestbroadcastVariableMsg()
optional .protobuf.RequestBroadcastVariableMessage requestbroadcastVariableMsg = 14;
- Returns:
- The requestbroadcastVariableMsg.
-
getRequestbroadcastVariableMsgOrBuilder
ControlMessage.RequestBroadcastVariableMessageOrBuilder getRequestbroadcastVariableMsgOrBuilder()
optional .protobuf.RequestBroadcastVariableMessage requestbroadcastVariableMsg = 14;
-
hasBroadcastVariableMsg
boolean hasBroadcastVariableMsg()
optional .protobuf.InMasterBroadcastVariableMessage broadcastVariableMsg = 15;
- Returns:
- Whether the broadcastVariableMsg field is set.
-
getBroadcastVariableMsg
ControlMessage.InMasterBroadcastVariableMessage getBroadcastVariableMsg()
optional .protobuf.InMasterBroadcastVariableMessage broadcastVariableMsg = 15;
- Returns:
- The broadcastVariableMsg.
-
getBroadcastVariableMsgOrBuilder
ControlMessage.InMasterBroadcastVariableMessageOrBuilder getBroadcastVariableMsgOrBuilder()
optional .protobuf.InMasterBroadcastVariableMessage broadcastVariableMsg = 15;
-
hasPipeInitMsg
boolean hasPipeInitMsg()
optional .protobuf.PipeInitMessage pipeInitMsg = 16;
- Returns:
- Whether the pipeInitMsg field is set.
-
getPipeInitMsg
ControlMessage.PipeInitMessage getPipeInitMsg()
optional .protobuf.PipeInitMessage pipeInitMsg = 16;
- Returns:
- The pipeInitMsg.
-
getPipeInitMsgOrBuilder
ControlMessage.PipeInitMessageOrBuilder getPipeInitMsgOrBuilder()
optional .protobuf.PipeInitMessage pipeInitMsg = 16;
-
hasRequestPipeLocMsg
boolean hasRequestPipeLocMsg()
optional .protobuf.RequestPipeLocationMessage requestPipeLocMsg = 17;
- Returns:
- Whether the requestPipeLocMsg field is set.
-
getRequestPipeLocMsg
ControlMessage.RequestPipeLocationMessage getRequestPipeLocMsg()
optional .protobuf.RequestPipeLocationMessage requestPipeLocMsg = 17;
- Returns:
- The requestPipeLocMsg.
-
getRequestPipeLocMsgOrBuilder
ControlMessage.RequestPipeLocationMessageOrBuilder getRequestPipeLocMsgOrBuilder()
optional .protobuf.RequestPipeLocationMessage requestPipeLocMsg = 17;
-
hasPipeLocInfoMsg
boolean hasPipeLocInfoMsg()
optional .protobuf.PipeLocationInfoMessage pipeLocInfoMsg = 18;
- Returns:
- Whether the pipeLocInfoMsg field is set.
-
getPipeLocInfoMsg
ControlMessage.PipeLocationInfoMessage getPipeLocInfoMsg()
optional .protobuf.PipeLocationInfoMessage pipeLocInfoMsg = 18;
- Returns:
- The pipeLocInfoMsg.
-
getPipeLocInfoMsgOrBuilder
ControlMessage.PipeLocationInfoMessageOrBuilder getPipeLocInfoMsgOrBuilder()
optional .protobuf.PipeLocationInfoMessage pipeLocInfoMsg = 18;
-
-