Class TaskMetrics

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

public class TaskMetrics extends Object
  • Method Details

    • diskBytesSpilled

      public long diskBytesSpilled()
    • executorCpuTime

      public long executorCpuTime()
    • executorDeserializeCpuTime

      public long executorDeserializeCpuTime()
    • executorDeserializeTime

      public long executorDeserializeTime()
    • executorRunTime

      public long executorRunTime()
    • inputMetrics

      public InputMetrics inputMetrics()
    • jvmGcTime

      public long jvmGcTime()
    • memoryBytesSpilled

      public long memoryBytesSpilled()
    • outputMetrics

      public OutputMetrics outputMetrics()
    • peakExecutionMemory

      public long peakExecutionMemory()
    • resultSerializationTime

      public long resultSerializationTime()
    • resultSize

      public long resultSize()
    • shuffleReadMetrics

      public ShuffleReadMetrics shuffleReadMetrics()
    • shuffleWriteMetrics

      public ShuffleWriteMetrics shuffleWriteMetrics()