From 356c8d7e4d4cc5c094cab39de81a311b62b244f2 Mon Sep 17 00:00:00 2001 From: Steve Vaughan Jr Date: Sat, 16 Mar 2024 16:24:43 -0400 Subject: [PATCH] Update PartitionMetricsWriteInfo.java --- .../spark/sql/connector/write/PartitionMetricsWriteInfo.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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); } /**