ExecutorMetricsDistributions (Spark 3.4.1 JavaDoc)

public class ExecutorMetricsDistributions
extends Object

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

Methods inherited from class Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

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

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

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

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

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

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

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

public ExecutorPeakMetricsDistributions peakMemoryMetrics()

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

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

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

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

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

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

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

Class ExecutorMetricsDistributions