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

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

public class TaskMetricDistributions
extends Object

Method Summary

scala.collection.IndexedSeq<Object>	diskBytesSpilled()
scala.collection.IndexedSeq<Object>	executorDeserializeTime()
scala.collection.IndexedSeq<Object>	executorRunTime()
scala.Option<InputMetricDistributions>	inputMetrics()
scala.collection.IndexedSeq<Object>	jvmGcTime()
scala.collection.IndexedSeq<Object>	memoryBytesSpilled()
scala.Option<OutputMetricDistributions>	outputMetrics()
scala.collection.IndexedSeq<Object>	quantiles()
scala.collection.IndexedSeq<Object>	resultSerializationTime()
scala.collection.IndexedSeq<Object>	resultSize()
scala.Option<ShuffleReadMetricDistributions>	shuffleReadMetrics()
scala.Option<ShuffleWriteMetricDistributions>	shuffleWriteMetrics()

Methods inherited from class Object

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

Method Detail

quantiles

public scala.collection.IndexedSeq<Object> quantiles()

executorDeserializeTime

public scala.collection.IndexedSeq<Object> executorDeserializeTime()

executorRunTime

public scala.collection.IndexedSeq<Object> executorRunTime()

resultSize

public scala.collection.IndexedSeq<Object> resultSize()

jvmGcTime

public scala.collection.IndexedSeq<Object> jvmGcTime()

resultSerializationTime

public scala.collection.IndexedSeq<Object> resultSerializationTime()

memoryBytesSpilled

public scala.collection.IndexedSeq<Object> memoryBytesSpilled()

diskBytesSpilled

public scala.collection.IndexedSeq<Object> diskBytesSpilled()

inputMetrics

public scala.Option<InputMetricDistributions> inputMetrics()

outputMetrics

public scala.Option<OutputMetricDistributions> outputMetrics()

shuffleReadMetrics

public scala.Option<ShuffleReadMetricDistributions> shuffleReadMetrics()

shuffleWriteMetrics

public scala.Option<ShuffleWriteMetricDistributions> shuffleWriteMetrics()