diff --git a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/PartitionMetricsWriteInfo.java b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/PartitionMetricsWriteInfo.java index a79a047dcf2f0..71dafb1847587 100644 --- a/sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/PartitionMetricsWriteInfo.java +++ b/sql/catalyst/src/main/java/org/apache/spark/sql/connector/write/PartitionMetricsWriteInfo.java @@ -37,7 +37,7 @@ public class PartitionMetricsWriteInfo { * * @param otherAccumulator Another object containing aggregated partition metrics */ - public void merge (PartitionMetricsWriteInfo otherAccumulator) { + public void merge(PartitionMetricsWriteInfo otherAccumulator) { otherAccumulator.metrics.forEach((p, m) -> metrics.computeIfAbsent(p, key -> new PartitionMetrics(0L, 0L, 0)) .merge(m)); @@ -66,7 +66,7 @@ public void update(String partitionPath, long bytes, long records, int files) { * @param records the number of addition records */ public void updateFile(String partitionPath, long bytes, long records) { - update (partitionPath, bytes, records, 1); + update(partitionPath, bytes, records, 1); } /**