Class StreamingStatistics

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

public class StreamingStatistics extends Object
  • 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()