@Evolving public interface ReportsSourceMetrics extends SparkDataStream
SparkDataStreamstreaming sources to signal that they can report metrics.
|Modifier and Type||Method and Description|
Returns the metrics reported by the streaming source with respect to the latest consumed offset.
commit, deserializeOffset, initialOffset, stop
java.util.Map<String,String> metrics(java.util.Optional<Offset> latestConsumedOffset)
latestConsumedOffset- the end offset (exclusive) of the latest triggered batch.