diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ReportsSourceMetrics.java b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ReportsSourceMetrics.java index 3253e24abdb4a..705cd1ad04be9 100644 --- a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ReportsSourceMetrics.java +++ b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ReportsSourceMetrics.java @@ -29,9 +29,10 @@ @Evolving public interface ReportsSourceMetrics extends SparkDataStream { /** - * Returns the metrics reported by the streaming source with respect to the latest consumed offset. + * Returns the metrics reported by the streaming source with respect to + * the latest consumed offset. * - * @param latestConsumedOffset the end offset (exclusive) consumed of the latest triggered batch. + * @param latestConsumedOffset the end offset (exclusive) of the latest triggered batch. */ Map metrics(Optional latestConsumedOffset); }