Skip to content

Commit 2f13f28

Browse files
committed
fix style
1 parent 7c7ba91 commit 2f13f28

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

sql/catalyst/src/main/java/org/apache/spark/sql/connector/read/streaming/ReportsSourceMetrics.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,9 +29,10 @@
2929
@Evolving
3030
public interface ReportsSourceMetrics extends SparkDataStream {
3131
/**
32-
* Returns the metrics reported by the streaming source with respect to the latest consumed offset.
32+
* Returns the metrics reported by the streaming source with respect to
33+
* the latest consumed offset.
3334
*
34-
* @param latestConsumedOffset the end offset (exclusive) consumed of the latest triggered batch.
35+
* @param latestConsumedOffset the end offset (exclusive) of the latest triggered batch.
3536
*/
3637
Map<String, String> metrics(Optional<Offset> latestConsumedOffset);
3738
}

0 commit comments

Comments
 (0)