Update PartitionMetricsWriteInfo.java

snmvaughan · Mar 16, 2024 · 356c8d7 · 356c8d7
1 parent 2e6db78
commit 356c8d7
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...atalyst/src/main/java/org/apache/spark/sql/connector/write/PartitionMetricsWriteInfo.java b/...atalyst/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);
   }
 
   /**