org.apache.spark.status.api.v1

Class TaskMetrics

java.lang.Object

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

public class TaskMetrics
extends java.lang.Object

Method Summary

Methods

Modifier and Type	Method and Description
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 java.lang.Object

clone, equals, finalize, 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()