Class ExecutorMetricsDistributions

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

public class ExecutorMetricsDistributions extends Object
  • Method Details

    • diskBytesSpilled

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

      public scala.collection.IndexedSeq<Object> failedTasks()
    • inputBytes

      public scala.collection.IndexedSeq<Object> inputBytes()
    • inputRecords

      public scala.collection.IndexedSeq<Object> inputRecords()
    • killedTasks

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

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

      public scala.collection.IndexedSeq<Object> outputBytes()
    • outputRecords

      public scala.collection.IndexedSeq<Object> outputRecords()
    • peakMemoryMetrics

      public ExecutorPeakMetricsDistributions peakMemoryMetrics()
    • quantiles

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

      public scala.collection.IndexedSeq<Object> shuffleRead()
    • shuffleReadRecords

      public scala.collection.IndexedSeq<Object> shuffleReadRecords()
    • shuffleWrite

      public scala.collection.IndexedSeq<Object> shuffleWrite()
    • shuffleWriteRecords

      public scala.collection.IndexedSeq<Object> shuffleWriteRecords()
    • succeededTasks

      public scala.collection.IndexedSeq<Object> succeededTasks()
    • taskTime

      public scala.collection.IndexedSeq<Object> taskTime()