Class StreamingStatistics
Object
org.apache.spark.status.api.v1.streaming.StreamingStatistics
-
Method Details
-
avgInputRate
-
avgProcessingTime
-
avgSchedulingDelay
-
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
-