public class StreamingStatistics
extends Object
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() |
public java.util.Date startTime()
public long batchDuration()
public int numReceivers()
public int numActiveReceivers()
public int numInactiveReceivers()
public long numTotalCompletedBatches()
public long numRetainedCompletedBatches()
public long numActiveBatches()
public long numProcessedRecords()
public long numReceivedRecords()
public scala.Option<Object> avgInputRate()
public scala.Option<Object> avgSchedulingDelay()
public scala.Option<Object> avgProcessingTime()
public scala.Option<Object> avgTotalDelay()