Package org.apache.spark.status.protobuf

Interface StoreTypes.TaskDataOrBuilder

All Superinterfaces:
com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
All Known Implementing Classes:
StoreTypes.TaskData, StoreTypes.TaskData.Builder
Enclosing class:
StoreTypes
public static interface StoreTypes.TaskDataOrBuilder extends com.google.protobuf.MessageOrBuilder

  • Method Details

    • getTaskId

      long getTaskId()
      int64 task_id = 1;
      Returns:
      The taskId.

    • getIndex

      int getIndex()
      int32 index = 2;
      Returns:
      The index.

    • getAttempt

      int getAttempt()
      int32 attempt = 3;
      Returns:
      The attempt.

    • getPartitionId

      int getPartitionId()
      int32 partition_id = 4;
      Returns:
      The partitionId.

    • getLaunchTime

      long getLaunchTime()
      int64 launch_time = 5;
      Returns:
      The launchTime.

    • hasResultFetchStart

      boolean hasResultFetchStart()
      optional int64 result_fetch_start = 6;
      Returns:
      Whether the resultFetchStart field is set.

    • getResultFetchStart

      long getResultFetchStart()
      optional int64 result_fetch_start = 6;
      Returns:
      The resultFetchStart.

    • hasDuration

      boolean hasDuration()
      optional int64 duration = 7;
      Returns:
      Whether the duration field is set.

    • getDuration

      long getDuration()
      optional int64 duration = 7;
      Returns:
      The duration.

    • hasExecutorId

      boolean hasExecutorId()
      optional string executor_id = 8;
      Returns:
      Whether the executorId field is set.

    • getExecutorId

      String getExecutorId()
      optional string executor_id = 8;
      Returns:
      The executorId.

    • getExecutorIdBytes

      com.google.protobuf.ByteString getExecutorIdBytes()
      optional string executor_id = 8;
      Returns:
      The bytes for executorId.

    • hasHost

      boolean hasHost()
      optional string host = 9;
      Returns:
      Whether the host field is set.

    • getHost

      String getHost()
      optional string host = 9;
      Returns:
      The host.

    • getHostBytes

      com.google.protobuf.ByteString getHostBytes()
      optional string host = 9;
      Returns:
      The bytes for host.

    • hasStatus

      boolean hasStatus()
      optional string status = 10;
      Returns:
      Whether the status field is set.

    • getStatus

      String getStatus()
      optional string status = 10;
      Returns:
      The status.

    • getStatusBytes

      com.google.protobuf.ByteString getStatusBytes()
      optional string status = 10;
      Returns:
      The bytes for status.

    • hasTaskLocality

      boolean hasTaskLocality()
      optional string task_locality = 11;
      Returns:
      Whether the taskLocality field is set.

    • getTaskLocality

      String getTaskLocality()
      optional string task_locality = 11;
      Returns:
      The taskLocality.

    • getTaskLocalityBytes

      com.google.protobuf.ByteString getTaskLocalityBytes()
      optional string task_locality = 11;
      Returns:
      The bytes for taskLocality.

    • getSpeculative

      boolean getSpeculative()
      bool speculative = 12;
      Returns:
      The speculative.

    • getAccumulatorUpdatesList

      List<StoreTypes.AccumulableInfo> getAccumulatorUpdatesList()
      repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

    • getAccumulatorUpdates

      StoreTypes.AccumulableInfo getAccumulatorUpdates(int index)
      repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

    • getAccumulatorUpdatesCount

      int getAccumulatorUpdatesCount()
      repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

    • getAccumulatorUpdatesOrBuilderList

      List<? extends StoreTypes.AccumulableInfoOrBuilder> getAccumulatorUpdatesOrBuilderList()
      repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

    • getAccumulatorUpdatesOrBuilder

      StoreTypes.AccumulableInfoOrBuilder getAccumulatorUpdatesOrBuilder(int index)
      repeated .org.apache.spark.status.protobuf.AccumulableInfo accumulator_updates = 13;

    • hasErrorMessage

      boolean hasErrorMessage()
      optional string error_message = 14;
      Returns:
      Whether the errorMessage field is set.

    • getErrorMessage

      String getErrorMessage()
      optional string error_message = 14;
      Returns:
      The errorMessage.

    • getErrorMessageBytes

      com.google.protobuf.ByteString getErrorMessageBytes()
      optional string error_message = 14;
      Returns:
      The bytes for errorMessage.

    • hasTaskMetrics

      boolean hasTaskMetrics()
      optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;
      Returns:
      Whether the taskMetrics field is set.

    • getTaskMetrics

      StoreTypes.TaskMetrics getTaskMetrics()
      optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;
      Returns:
      The taskMetrics.

    • getTaskMetricsOrBuilder

      StoreTypes.TaskMetricsOrBuilder getTaskMetricsOrBuilder()
      optional .org.apache.spark.status.protobuf.TaskMetrics task_metrics = 15;

    • getExecutorLogsCount

      int getExecutorLogsCount()
      map<string, string> executor_logs = 16;

    • containsExecutorLogs

      boolean containsExecutorLogs(String key)
      map<string, string> executor_logs = 16;

    • getExecutorLogs

      @Deprecated Map<String,String> getExecutorLogs()
      Deprecated.
      Use getExecutorLogsMap() instead.

    • getExecutorLogsMap

      Map<String,String> getExecutorLogsMap()
      map<string, string> executor_logs = 16;

    • getExecutorLogsOrDefault

      String getExecutorLogsOrDefault(String key, String defaultValue)
      map<string, string> executor_logs = 16;

    • getExecutorLogsOrThrow

      String getExecutorLogsOrThrow(String key)
      map<string, string> executor_logs = 16;

    • getSchedulerDelay

      long getSchedulerDelay()
      int64 scheduler_delay = 17;
      Returns:
      The schedulerDelay.

    • getGettingResultTime

      long getGettingResultTime()
      int64 getting_result_time = 18;
      Returns:
      The gettingResultTime.