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.