From 4e8accc179d8f60c874d748167018196900b7d12 Mon Sep 17 00:00:00 2001
From: Y Ethan Guo <ethan.guoyihua@gmail.com>
Date: Tue, 22 Feb 2022 20:57:02 -0800
Subject: [PATCH] [HUDI-3486] Fix wrong field order for constructing
 HoodieMetadataColumnStats (#4875)

---
 .../hudi/metadata/HoodieMetadataPayload.java  | 20 +++++++++----------
 1 file changed, 10 insertions(+), 10 deletions(-)

diff --git a/hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataPayload.java b/hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataPayload.java
index 3517e17b1..3730cccee 100644
--- a/hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataPayload.java
+++ b/hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataPayload.java
@@ -157,16 +157,16 @@ public class HoodieMetadataPayload implements HoodieRecordPayload<HoodieMetadata
         if (v == null) {
           throw new HoodieMetadataException("Valid " + SCHEMA_FIELD_ID_COLUMN_STATS + " record expected for type: " + METADATA_TYPE_COLUMN_STATS);
         }
-        columnStatMetadata = new HoodieMetadataColumnStats(
-            (String) v.get(COLUMN_STATS_FIELD_RESOURCE_NAME),
-            (String) v.get(COLUMN_STATS_FIELD_MIN_VALUE),
-            (String) v.get(COLUMN_STATS_FIELD_MAX_VALUE),
-            (Long) v.get(COLUMN_STATS_FIELD_NULL_COUNT),
-            (Long) v.get(COLUMN_STATS_FIELD_VALUE_COUNT),
-            (Long) v.get(COLUMN_STATS_FIELD_TOTAL_SIZE),
-            (Long) v.get(COLUMN_STATS_FIELD_TOTAL_UNCOMPRESSED_SIZE),
-            (Boolean) v.get(COLUMN_STATS_FIELD_IS_DELETED)
-        );
+        columnStatMetadata = HoodieMetadataColumnStats.newBuilder()
+            .setFileName((String) v.get(COLUMN_STATS_FIELD_RESOURCE_NAME))
+            .setMinValue((String) v.get(COLUMN_STATS_FIELD_MIN_VALUE))
+            .setMaxValue((String) v.get(COLUMN_STATS_FIELD_MAX_VALUE))
+            .setValueCount((Long) v.get(COLUMN_STATS_FIELD_VALUE_COUNT))
+            .setNullCount((Long) v.get(COLUMN_STATS_FIELD_NULL_COUNT))
+            .setTotalSize((Long) v.get(COLUMN_STATS_FIELD_TOTAL_SIZE))
+            .setTotalUncompressedSize((Long) v.get(COLUMN_STATS_FIELD_TOTAL_UNCOMPRESSED_SIZE))
+            .setIsDeleted((Boolean) v.get(COLUMN_STATS_FIELD_IS_DELETED))
+            .build();
       }
     }
   }