BatchInfo

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

val batchTime: Time

Time of the batch

def clone(): AnyRef

final def eq(arg0: AnyRef): Boolean

def finalize(): Unit

final def getClass(): Class[_]

final def isInstanceOf[T0]: Boolean

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def numRecords: Long

The number of recorders received by the receivers in this batch.

def processingDelay: Option[Long]

Time taken for the all jobs of this batch to finish processing from the time they started processing.

val processingEndTime: Option[Long]

Clock time of when the last job of this batch finished processing

val processingStartTime: Option[Long]

Clock time of when the first job of this batch started processing

def schedulingDelay: Option[Long]

Time taken for the first job of this batch to start processing from the time this batch was submitted to the streaming scheduler.

val streamIdToInputInfo: Map[Int, StreamInputInfo]

A map of input stream id to its input info

val submissionTime: Long

Clock time of when jobs of this batch was submitted to the streaming scheduler queue

final def synchronized[T0](arg0: ⇒ T0): T0

def totalDelay: Option[Long]

Time taken for all the jobs of this batch to finish processing from the time they were submitted.

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

def streamIdToNumRecords: Map[Int, Long]