Interface ReportsSourceMetrics
- All Superinterfaces:
SparkDataStream
A mix-in interface for
SparkDataStream
streaming sources to signal that they can report
metrics.- Since:
- 3.2.0
-
Method Summary
Methods inherited from interface org.apache.spark.sql.connector.read.streaming.SparkDataStream
commit, deserializeOffset, initialOffset, stop
-
Method Details
-
metrics
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.
-