StreamingStatistics (Spark 3.4.2 JavaDoc)

public class StreamingStatistics
extends Object

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`scala.Option<Object>`	`avgInputRate()`
`scala.Option<Object>`	`avgProcessingTime()`
`scala.Option<Object>`	`avgSchedulingDelay()`
`scala.Option<Object>`	`avgTotalDelay()`
`long`	`batchDuration()`
`long`	`numActiveBatches()`
`int`	`numActiveReceivers()`
`int`	`numInactiveReceivers()`
`long`	`numProcessedRecords()`
`long`	`numReceivedRecords()`
`int`	`numReceivers()`
`long`	`numRetainedCompletedBatches()`
`long`	`numTotalCompletedBatches()`
`java.util.Date`	`startTime()`

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

public scala.Option<Object> avgInputRate()

public scala.Option<Object> avgProcessingTime()

public scala.Option<Object> avgSchedulingDelay()

public scala.Option<Object> avgTotalDelay()

public long numRetainedCompletedBatches()

public long numTotalCompletedBatches()

Class StreamingStatistics