org.apache.spark.status.api.v1

Class TaskMetrics

Object

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

public class TaskMetrics
extends Object

Method Summary

Modifier and Type	Method and Description
long	diskBytesSpilled()
long	executorCpuTime()
long	executorDeserializeCpuTime()
long	executorDeserializeTime()
long	executorRunTime()
InputMetrics	inputMetrics()
long	jvmGcTime()
long	memoryBytesSpilled()
OutputMetrics	outputMetrics()
long	peakExecutionMemory()
long	resultSerializationTime()
long	resultSize()
ShuffleReadMetrics	shuffleReadMetrics()
ShuffleWriteMetrics	shuffleWriteMetrics()

Methods inherited from class Object

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

Method Detail

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