Interface ControlMessage.MessageOrBuilder

    • Method Detail

      • hasType

        boolean hasType()
        required .protobuf.MessageType type = 1;
        Returns:
        Whether the type field is set.
      • 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.
      • 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.
      • 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.
      • 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.
      • 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.
      • 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.
      • 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.
      • 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.
      • 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.
      • hasDataCollected

        boolean hasDataCollected()
        optional .protobuf.DataCollectMessage dataCollected = 13;
        Returns:
        Whether the dataCollected field is set.
      • 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.
      • hasBroadcastVariableMsg

        boolean hasBroadcastVariableMsg()
        optional .protobuf.InMasterBroadcastVariableMessage broadcastVariableMsg = 15;
        Returns:
        Whether the broadcastVariableMsg field is set.
      • hasPipeInitMsg

        boolean hasPipeInitMsg()
        optional .protobuf.PipeInitMessage pipeInitMsg = 16;
        Returns:
        Whether the pipeInitMsg field is set.
      • hasRequestPipeLocMsg

        boolean hasRequestPipeLocMsg()
        optional .protobuf.RequestPipeLocationMessage requestPipeLocMsg = 17;
        Returns:
        Whether the requestPipeLocMsg field is set.
      • hasPipeLocInfoMsg

        boolean hasPipeLocInfoMsg()
        optional .protobuf.PipeLocationInfoMessage pipeLocInfoMsg = 18;
        Returns:
        Whether the pipeLocInfoMsg field is set.