Package org.apache.spark.status.protobuf

Interface StoreTypes.ExecutorStageSummaryOrBuilder

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

  • Method Details

    • getTaskTime

      long getTaskTime()
      int64 task_time = 1;
      Returns:
      The taskTime.

    • getFailedTasks

      int getFailedTasks()
      int32 failed_tasks = 2;
      Returns:
      The failedTasks.

    • getSucceededTasks

      int getSucceededTasks()
      int32 succeeded_tasks = 3;
      Returns:
      The succeededTasks.

    • getKilledTasks

      int getKilledTasks()
      int32 killed_tasks = 4;
      Returns:
      The killedTasks.

    • getInputBytes

      long getInputBytes()
      int64 input_bytes = 5;
      Returns:
      The inputBytes.

    • getInputRecords

      long getInputRecords()
      int64 input_records = 6;
      Returns:
      The inputRecords.

    • getOutputBytes

      long getOutputBytes()
      int64 output_bytes = 7;
      Returns:
      The outputBytes.

    • getOutputRecords

      long getOutputRecords()
      int64 output_records = 8;
      Returns:
      The outputRecords.

    • getShuffleRead

      long getShuffleRead()
      int64 shuffle_read = 9;
      Returns:
      The shuffleRead.

    • getShuffleReadRecords

      long getShuffleReadRecords()
      int64 shuffle_read_records = 10;
      Returns:
      The shuffleReadRecords.

    • getShuffleWrite

      long getShuffleWrite()
      int64 shuffle_write = 11;
      Returns:
      The shuffleWrite.

    • getShuffleWriteRecords

      long getShuffleWriteRecords()
      int64 shuffle_write_records = 12;
      Returns:
      The shuffleWriteRecords.

    • getMemoryBytesSpilled

      long getMemoryBytesSpilled()
      int64 memory_bytes_spilled = 13;
      Returns:
      The memoryBytesSpilled.

    • getDiskBytesSpilled

      long getDiskBytesSpilled()
      int64 disk_bytes_spilled = 14;
      Returns:
      The diskBytesSpilled.

    • getIsBlacklistedForStage

      boolean getIsBlacklistedForStage()
      bool is_blacklisted_for_stage = 15;
      Returns:
      The isBlacklistedForStage.

    • hasPeakMemoryMetrics

      boolean hasPeakMemoryMetrics()
      optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;
      Returns:
      Whether the peakMemoryMetrics field is set.

    • getPeakMemoryMetrics

      StoreTypes.ExecutorMetrics getPeakMemoryMetrics()
      optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;
      Returns:
      The peakMemoryMetrics.

    • getPeakMemoryMetricsOrBuilder

      StoreTypes.ExecutorMetricsOrBuilder getPeakMemoryMetricsOrBuilder()
      optional .org.apache.spark.status.protobuf.ExecutorMetrics peak_memory_metrics = 16;

    • getIsExcludedForStage

      boolean getIsExcludedForStage()
      bool is_excluded_for_stage = 17;
      Returns:
      The isExcludedForStage.