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

Class ExecutorStageSummary

Object
org.apache.spark.status.api.v1.ExecutorStageSummary
public class ExecutorStageSummary extends Object

  • Method Details

    • diskBytesSpilled

      public long diskBytesSpilled()

    • failedTasks

      public int failedTasks()

    • inputBytes

      public long inputBytes()

    • inputRecords

      public long inputRecords()

    • isBlacklistedForStage

      public boolean isBlacklistedForStage()
      Deprecated.
      use isExcludedForStage instead. Since 3.1.0.

    • isExcludedForStage

      public boolean isExcludedForStage()

    • killedTasks

      public int killedTasks()

    • memoryBytesSpilled

      public long memoryBytesSpilled()

    • outputBytes

      public long outputBytes()

    • outputRecords

      public long outputRecords()

    • peakMemoryMetrics

      public scala.Option<org.apache.spark.executor.ExecutorMetrics> peakMemoryMetrics()

    • shuffleRead

      public long shuffleRead()

    • shuffleReadRecords

      public long shuffleReadRecords()

    • shuffleWrite

      public long shuffleWrite()

    • shuffleWriteRecords

      public long shuffleWriteRecords()

    • succeededTasks

      public int succeededTasks()

    • taskTime

      public long taskTime()