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

Class StreamingStatistics

Object

org.apache.spark.status.api.v1.streaming.StreamingStatistics

public class StreamingStatistics
extends Object

Method Summary

Modifier and Type	Method	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()
Date	startTime()

Methods inherited from class java.lang.Object

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

Method Details

avgInputRate

public scala.Option<Object> avgInputRate()

avgProcessingTime

public scala.Option<Object> avgProcessingTime()

avgSchedulingDelay

public scala.Option<Object> avgSchedulingDelay()

avgTotalDelay

public scala.Option<Object> avgTotalDelay()

batchDuration

public long batchDuration()

numActiveBatches

public long numActiveBatches()

numActiveReceivers

public int numActiveReceivers()

numInactiveReceivers

public int numInactiveReceivers()

numProcessedRecords

public long numProcessedRecords()

numReceivedRecords

public long numReceivedRecords()

numReceivers

public int numReceivers()

numRetainedCompletedBatches

public long numRetainedCompletedBatches()

numTotalCompletedBatches

public long numTotalCompletedBatches()

startTime

public Date startTime()