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

Class ExecutorMetricsDistributions

Object

org.apache.spark.status.api.v1.ExecutorMetricsDistributions

public class ExecutorMetricsDistributions
extends Object

Method Summary

Modifier and Type	Method	Description
scala.collection.immutable.IndexedSeq<Object>	diskBytesSpilled()
scala.collection.immutable.IndexedSeq<Object>	failedTasks()
scala.collection.immutable.IndexedSeq<Object>	inputBytes()
scala.collection.immutable.IndexedSeq<Object>	inputRecords()
scala.collection.immutable.IndexedSeq<Object>	killedTasks()
scala.collection.immutable.IndexedSeq<Object>	memoryBytesSpilled()
scala.collection.immutable.IndexedSeq<Object>	outputBytes()
scala.collection.immutable.IndexedSeq<Object>	outputRecords()
ExecutorPeakMetricsDistributions	peakMemoryMetrics()
scala.collection.immutable.IndexedSeq<Object>	quantiles()
scala.collection.immutable.IndexedSeq<Object>	shuffleRead()
scala.collection.immutable.IndexedSeq<Object>	shuffleReadRecords()
scala.collection.immutable.IndexedSeq<Object>	shuffleWrite()
scala.collection.immutable.IndexedSeq<Object>	shuffleWriteRecords()
scala.collection.immutable.IndexedSeq<Object>	succeededTasks()
scala.collection.immutable.IndexedSeq<Object>	taskTime()

Methods inherited from class java.lang.Object

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

Method Details

diskBytesSpilled

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

failedTasks

public scala.collection.immutable.IndexedSeq<Object> failedTasks()

inputBytes

public scala.collection.immutable.IndexedSeq<Object> inputBytes()

inputRecords

public scala.collection.immutable.IndexedSeq<Object> inputRecords()

killedTasks

public scala.collection.immutable.IndexedSeq<Object> killedTasks()

memoryBytesSpilled

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

outputBytes

public scala.collection.immutable.IndexedSeq<Object> outputBytes()

outputRecords

public scala.collection.immutable.IndexedSeq<Object> outputRecords()

peakMemoryMetrics

public ExecutorPeakMetricsDistributions peakMemoryMetrics()

quantiles

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

shuffleRead

public scala.collection.immutable.IndexedSeq<Object> shuffleRead()

shuffleReadRecords

public scala.collection.immutable.IndexedSeq<Object> shuffleReadRecords()

shuffleWrite

public scala.collection.immutable.IndexedSeq<Object> shuffleWrite()

shuffleWriteRecords

public scala.collection.immutable.IndexedSeq<Object> shuffleWriteRecords()

succeededTasks

public scala.collection.immutable.IndexedSeq<Object> succeededTasks()

taskTime

public scala.collection.immutable.IndexedSeq<Object> taskTime()