Class BatchInfo

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

public class BatchInfo extends Object
  • Method Details

    • batchDuration

      public long batchDuration()
    • batchId

      public long batchId()
    • batchTime

      public Date batchTime()
    • firstFailureReason

      public scala.Option<String> firstFailureReason()
    • inputSize

      public long inputSize()
    • numActiveOutputOps

      public int numActiveOutputOps()
    • numCompletedOutputOps

      public int numCompletedOutputOps()
    • numFailedOutputOps

      public int numFailedOutputOps()
    • numTotalOutputOps

      public int numTotalOutputOps()
    • processingTime

      public scala.Option<Object> processingTime()
    • schedulingDelay

      public scala.Option<Object> schedulingDelay()
    • status

      public String status()
    • totalDelay

      public scala.Option<Object> totalDelay()