Package org.apache.spark.status.api.v1

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()