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

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