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

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

public class TaskMetrics
extends Object

Method Summary

long	diskBytesSpilled()
long	executorDeserializeTime()
long	executorRunTime()
scala.Option<InputMetrics>	inputMetrics()
long	jvmGcTime()
long	memoryBytesSpilled()
scala.Option<OutputMetrics>	outputMetrics()
long	resultSerializationTime()
long	resultSize()
scala.Option<ShuffleReadMetrics>	shuffleReadMetrics()
scala.Option<ShuffleWriteMetrics>	shuffleWriteMetrics()

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

executorDeserializeTime

public long executorDeserializeTime()

executorRunTime

public long executorRunTime()

resultSize

public long resultSize()

jvmGcTime

public long jvmGcTime()

resultSerializationTime

public long resultSerializationTime()

memoryBytesSpilled

public long memoryBytesSpilled()

diskBytesSpilled

public long diskBytesSpilled()

inputMetrics

public scala.Option<InputMetrics> inputMetrics()

outputMetrics

public scala.Option<OutputMetrics> outputMetrics()

shuffleReadMetrics

public scala.Option<ShuffleReadMetrics> shuffleReadMetrics()

shuffleWriteMetrics

public scala.Option<ShuffleWriteMetrics> shuffleWriteMetrics()