ReportsSourceMetrics¶

ReportsSourceMetrics is an extension of the SparkDataStream abstraction for data streams with metrics.

Contract¶

Performance Metrics¶

Map<String, String> metrics(
  Optional<Offset> latestConsumedOffset)

Metrics of this SparkDataStream for the latest consumed offset (to create a SourceProgress for a StreamingQueryProgress)

See KafkaMicroBatchStream

Used when:

• ProgressReporter is requested to finish up a micro-batch

Implementations¶

• KafkaMicroBatchStream