Interface ControlMessage.MessageOrBuilder

    • Method Detail

      • hasType

        boolean hasType()
        required .protobuf.MessageType type = 1;
      • hasId

        boolean hasId()
        required int64 id = 2;
      • getId

        long getId()
        required int64 id = 2;
      • hasListenerId

        boolean hasListenerId()
        required string listenerId = 3;
         The id of the message listener (handler).
         
      • getListenerId

        String getListenerId()
        required string listenerId = 3;
         The id of the message listener (handler).
         
      • getListenerIdBytes

        com.google.protobuf.ByteString getListenerIdBytes()
        required string listenerId = 3;
         The id of the message listener (handler).
         
      • hasTaskStateChangedMsg

        boolean hasTaskStateChangedMsg()
        optional .protobuf.TaskStateChangedMsg taskStateChangedMsg = 4;
      • hasScheduleTaskMsg

        boolean hasScheduleTaskMsg()
        optional .protobuf.ScheduleTaskMsg scheduleTaskMsg = 5;
      • hasBlockStateChangedMsg

        boolean hasBlockStateChangedMsg()
        optional .protobuf.BlockStateChangedMsg blockStateChangedMsg = 6;
      • hasRunTimePassMessageMsg

        boolean hasRunTimePassMessageMsg()
        optional .protobuf.RunTimePassMessageMsg runTimePassMessageMsg = 7;
      • hasRequestBlockLocationMsg

        boolean hasRequestBlockLocationMsg()
        optional .protobuf.RequestBlockLocationMsg requestBlockLocationMsg = 8;
      • hasBlockLocationInfoMsg

        boolean hasBlockLocationInfoMsg()
        optional .protobuf.BlockLocationInfoMsg blockLocationInfoMsg = 9;
      • hasExecutorFailedMsg

        boolean hasExecutorFailedMsg()
        optional .protobuf.ExecutorFailedMsg executorFailedMsg = 10;
      • hasContainerFailedMsg

        boolean hasContainerFailedMsg()
        optional .protobuf.ContainerFailedMsg containerFailedMsg = 11;
      • hasMetricMsg

        boolean hasMetricMsg()
        optional .protobuf.MetricMsg metricMsg = 12;
      • hasDataCollected

        boolean hasDataCollected()
        optional .protobuf.DataCollectMessage dataCollected = 13;
      • hasRequestbroadcastVariableMsg

        boolean hasRequestbroadcastVariableMsg()
        optional .protobuf.RequestBroadcastVariableMessage requestbroadcastVariableMsg = 14;
      • hasBroadcastVariableMsg

        boolean hasBroadcastVariableMsg()
        optional .protobuf.InMasterBroadcastVariableMessage broadcastVariableMsg = 15;
      • hasPipeInitMsg

        boolean hasPipeInitMsg()
        optional .protobuf.PipeInitMessage pipeInitMsg = 16;
      • hasRequestPipeLocMsg

        boolean hasRequestPipeLocMsg()
        optional .protobuf.RequestPipeLocationMessage requestPipeLocMsg = 17;
      • hasPipeLocInfoMsg

        boolean hasPipeLocInfoMsg()
        optional .protobuf.PipeLocationInfoMessage pipeLocInfoMsg = 18;