Class TaskMetricDistributions

Object
org.apache.spark.status.api.v1.TaskMetricDistributions

public class TaskMetricDistributions extends Object
  • Method Details

    • diskBytesSpilled

      public scala.collection.IndexedSeq<Object> diskBytesSpilled()
    • duration

      public scala.collection.IndexedSeq<Object> duration()
    • executorCpuTime

      public scala.collection.IndexedSeq<Object> executorCpuTime()
    • executorDeserializeCpuTime

      public scala.collection.IndexedSeq<Object> executorDeserializeCpuTime()
    • executorDeserializeTime

      public scala.collection.IndexedSeq<Object> executorDeserializeTime()
    • executorRunTime

      public scala.collection.IndexedSeq<Object> executorRunTime()
    • gettingResultTime

      public scala.collection.IndexedSeq<Object> gettingResultTime()
    • inputMetrics

      public InputMetricDistributions inputMetrics()
    • jvmGcTime

      public scala.collection.IndexedSeq<Object> jvmGcTime()
    • memoryBytesSpilled

      public scala.collection.IndexedSeq<Object> memoryBytesSpilled()
    • outputMetrics

      public OutputMetricDistributions outputMetrics()
    • peakExecutionMemory

      public scala.collection.IndexedSeq<Object> peakExecutionMemory()
    • quantiles

      public scala.collection.IndexedSeq<Object> quantiles()
    • resultSerializationTime

      public scala.collection.IndexedSeq<Object> resultSerializationTime()
    • resultSize

      public scala.collection.IndexedSeq<Object> resultSize()
    • schedulerDelay

      public scala.collection.IndexedSeq<Object> schedulerDelay()
    • shuffleReadMetrics

      public ShuffleReadMetricDistributions shuffleReadMetrics()
    • shuffleWriteMetrics

      public ShuffleWriteMetricDistributions shuffleWriteMetrics()