Interface ReportsSourceMetrics

All Superinterfaces:
SparkDataStream

@Evolving public interface ReportsSourceMetrics extends SparkDataStream
A mix-in interface for SparkDataStream streaming sources to signal that they can report metrics.
Since:
3.2.0
  • Method Details

    • metrics

      Map<String,String> metrics(Optional<Offset> latestConsumedOffset)
      Returns the metrics reported by the streaming source with respect to the latest consumed offset.
      Parameters:
      latestConsumedOffset - the end offset (exclusive) of the latest triggered batch.