Class BatchInfo
Object
org.apache.spark.status.api.v1.streaming.BatchInfo
-
Method Details
-
batchDuration
public long batchDuration() -
batchId
public long batchId() -
batchTime
-
firstFailureReason
-
inputSize
public long inputSize() -
numActiveOutputOps
public int numActiveOutputOps() -
numCompletedOutputOps
public int numCompletedOutputOps() -
numFailedOutputOps
public int numFailedOutputOps() -
numTotalOutputOps
public int numTotalOutputOps() -
processingTime
-
schedulingDelay
-
status
-
totalDelay
-