Package org.apache.spark.status.protobuf

Interface StoreTypes.TaskMetricDistributionsOrBuilder

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

  • Method Details

    • getQuantilesList

      List<Double> getQuantilesList()
      repeated double quantiles = 1;
      Returns:
      A list containing the quantiles.

    • getQuantilesCount

      int getQuantilesCount()
      repeated double quantiles = 1;
      Returns:
      The count of quantiles.

    • getQuantiles

      double getQuantiles(int index)
      repeated double quantiles = 1;
      Parameters:
      index - The index of the element to return.
      Returns:
      The quantiles at the given index.

    • getDurationList

      List<Double> getDurationList()
      repeated double duration = 2;
      Returns:
      A list containing the duration.

    • getDurationCount

      int getDurationCount()
      repeated double duration = 2;
      Returns:
      The count of duration.

    • getDuration

      double getDuration(int index)
      repeated double duration = 2;
      Parameters:
      index - The index of the element to return.
      Returns:
      The duration at the given index.

    • getExecutorDeserializeTimeList

      List<Double> getExecutorDeserializeTimeList()
      repeated double executor_deserialize_time = 3;
      Returns:
      A list containing the executorDeserializeTime.

    • getExecutorDeserializeTimeCount

      int getExecutorDeserializeTimeCount()
      repeated double executor_deserialize_time = 3;
      Returns:
      The count of executorDeserializeTime.

    • getExecutorDeserializeTime

      double getExecutorDeserializeTime(int index)
      repeated double executor_deserialize_time = 3;
      Parameters:
      index - The index of the element to return.
      Returns:
      The executorDeserializeTime at the given index.

    • getExecutorDeserializeCpuTimeList

      List<Double> getExecutorDeserializeCpuTimeList()
      repeated double executor_deserialize_cpu_time = 4;
      Returns:
      A list containing the executorDeserializeCpuTime.

    • getExecutorDeserializeCpuTimeCount

      int getExecutorDeserializeCpuTimeCount()
      repeated double executor_deserialize_cpu_time = 4;
      Returns:
      The count of executorDeserializeCpuTime.

    • getExecutorDeserializeCpuTime

      double getExecutorDeserializeCpuTime(int index)
      repeated double executor_deserialize_cpu_time = 4;
      Parameters:
      index - The index of the element to return.
      Returns:
      The executorDeserializeCpuTime at the given index.

    • getExecutorRunTimeList

      List<Double> getExecutorRunTimeList()
      repeated double executor_run_time = 5;
      Returns:
      A list containing the executorRunTime.

    • getExecutorRunTimeCount

      int getExecutorRunTimeCount()
      repeated double executor_run_time = 5;
      Returns:
      The count of executorRunTime.

    • getExecutorRunTime

      double getExecutorRunTime(int index)
      repeated double executor_run_time = 5;
      Parameters:
      index - The index of the element to return.
      Returns:
      The executorRunTime at the given index.

    • getExecutorCpuTimeList

      List<Double> getExecutorCpuTimeList()
      repeated double executor_cpu_time = 6;
      Returns:
      A list containing the executorCpuTime.

    • getExecutorCpuTimeCount

      int getExecutorCpuTimeCount()
      repeated double executor_cpu_time = 6;
      Returns:
      The count of executorCpuTime.

    • getExecutorCpuTime

      double getExecutorCpuTime(int index)
      repeated double executor_cpu_time = 6;
      Parameters:
      index - The index of the element to return.
      Returns:
      The executorCpuTime at the given index.

    • getResultSizeList

      List<Double> getResultSizeList()
      repeated double result_size = 7;
      Returns:
      A list containing the resultSize.

    • getResultSizeCount

      int getResultSizeCount()
      repeated double result_size = 7;
      Returns:
      The count of resultSize.

    • getResultSize

      double getResultSize(int index)
      repeated double result_size = 7;
      Parameters:
      index - The index of the element to return.
      Returns:
      The resultSize at the given index.

    • getJvmGcTimeList

      List<Double> getJvmGcTimeList()
      repeated double jvm_gc_time = 8;
      Returns:
      A list containing the jvmGcTime.

    • getJvmGcTimeCount

      int getJvmGcTimeCount()
      repeated double jvm_gc_time = 8;
      Returns:
      The count of jvmGcTime.

    • getJvmGcTime

      double getJvmGcTime(int index)
      repeated double jvm_gc_time = 8;
      Parameters:
      index - The index of the element to return.
      Returns:
      The jvmGcTime at the given index.

    • getResultSerializationTimeList

      List<Double> getResultSerializationTimeList()
      repeated double result_serialization_time = 9;
      Returns:
      A list containing the resultSerializationTime.

    • getResultSerializationTimeCount

      int getResultSerializationTimeCount()
      repeated double result_serialization_time = 9;
      Returns:
      The count of resultSerializationTime.

    • getResultSerializationTime

      double getResultSerializationTime(int index)
      repeated double result_serialization_time = 9;
      Parameters:
      index - The index of the element to return.
      Returns:
      The resultSerializationTime at the given index.

    • getGettingResultTimeList

      List<Double> getGettingResultTimeList()
      repeated double getting_result_time = 10;
      Returns:
      A list containing the gettingResultTime.

    • getGettingResultTimeCount

      int getGettingResultTimeCount()
      repeated double getting_result_time = 10;
      Returns:
      The count of gettingResultTime.

    • getGettingResultTime

      double getGettingResultTime(int index)
      repeated double getting_result_time = 10;
      Parameters:
      index - The index of the element to return.
      Returns:
      The gettingResultTime at the given index.

    • getSchedulerDelayList

      List<Double> getSchedulerDelayList()
      repeated double scheduler_delay = 11;
      Returns:
      A list containing the schedulerDelay.

    • getSchedulerDelayCount

      int getSchedulerDelayCount()
      repeated double scheduler_delay = 11;
      Returns:
      The count of schedulerDelay.

    • getSchedulerDelay

      double getSchedulerDelay(int index)
      repeated double scheduler_delay = 11;
      Parameters:
      index - The index of the element to return.
      Returns:
      The schedulerDelay at the given index.

    • getPeakExecutionMemoryList

      List<Double> getPeakExecutionMemoryList()
      repeated double peak_execution_memory = 12;
      Returns:
      A list containing the peakExecutionMemory.

    • getPeakExecutionMemoryCount

      int getPeakExecutionMemoryCount()
      repeated double peak_execution_memory = 12;
      Returns:
      The count of peakExecutionMemory.

    • getPeakExecutionMemory

      double getPeakExecutionMemory(int index)
      repeated double peak_execution_memory = 12;
      Parameters:
      index - The index of the element to return.
      Returns:
      The peakExecutionMemory at the given index.

    • getMemoryBytesSpilledList

      List<Double> getMemoryBytesSpilledList()
      repeated double memory_bytes_spilled = 13;
      Returns:
      A list containing the memoryBytesSpilled.

    • getMemoryBytesSpilledCount

      int getMemoryBytesSpilledCount()
      repeated double memory_bytes_spilled = 13;
      Returns:
      The count of memoryBytesSpilled.

    • getMemoryBytesSpilled

      double getMemoryBytesSpilled(int index)
      repeated double memory_bytes_spilled = 13;
      Parameters:
      index - The index of the element to return.
      Returns:
      The memoryBytesSpilled at the given index.

    • getDiskBytesSpilledList

      List<Double> getDiskBytesSpilledList()
      repeated double disk_bytes_spilled = 14;
      Returns:
      A list containing the diskBytesSpilled.

    • getDiskBytesSpilledCount

      int getDiskBytesSpilledCount()
      repeated double disk_bytes_spilled = 14;
      Returns:
      The count of diskBytesSpilled.

    • getDiskBytesSpilled

      double getDiskBytesSpilled(int index)
      repeated double disk_bytes_spilled = 14;
      Parameters:
      index - The index of the element to return.
      Returns:
      The diskBytesSpilled at the given index.

    • hasInputMetrics

      boolean hasInputMetrics()
      .org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;
      Returns:
      Whether the inputMetrics field is set.

    • getInputMetrics

      StoreTypes.InputMetricDistributions getInputMetrics()
      .org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;
      Returns:
      The inputMetrics.

    • getInputMetricsOrBuilder

      StoreTypes.InputMetricDistributionsOrBuilder getInputMetricsOrBuilder()
      .org.apache.spark.status.protobuf.InputMetricDistributions input_metrics = 15;

    • hasOutputMetrics

      boolean hasOutputMetrics()
      .org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;
      Returns:
      Whether the outputMetrics field is set.

    • getOutputMetrics

      StoreTypes.OutputMetricDistributions getOutputMetrics()
      .org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;
      Returns:
      The outputMetrics.

    • getOutputMetricsOrBuilder

      StoreTypes.OutputMetricDistributionsOrBuilder getOutputMetricsOrBuilder()
      .org.apache.spark.status.protobuf.OutputMetricDistributions output_metrics = 16;

    • hasShuffleReadMetrics

      boolean hasShuffleReadMetrics()
      .org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;
      Returns:
      Whether the shuffleReadMetrics field is set.

    • getShuffleReadMetrics

      StoreTypes.ShuffleReadMetricDistributions getShuffleReadMetrics()
      .org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;
      Returns:
      The shuffleReadMetrics.

    • getShuffleReadMetricsOrBuilder

      StoreTypes.ShuffleReadMetricDistributionsOrBuilder getShuffleReadMetricsOrBuilder()
      .org.apache.spark.status.protobuf.ShuffleReadMetricDistributions shuffle_read_metrics = 17;

    • hasShuffleWriteMetrics

      boolean hasShuffleWriteMetrics()
      .org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;
      Returns:
      Whether the shuffleWriteMetrics field is set.

    • getShuffleWriteMetrics

      StoreTypes.ShuffleWriteMetricDistributions getShuffleWriteMetrics()
      .org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;
      Returns:
      The shuffleWriteMetrics.

    • getShuffleWriteMetricsOrBuilder

      StoreTypes.ShuffleWriteMetricDistributionsOrBuilder getShuffleWriteMetricsOrBuilder()
      .org.apache.spark.status.protobuf.ShuffleWriteMetricDistributions shuffle_write_metrics = 18;