update tests with unmapped values

Author: polyzos

fluss-client/src/main/java/org/apache/fluss/client/utils/ConverterUtils.java

@@ -55,8 +55,8 @@
  * Helper class for converting Java objects to Fluss's {@link InternalRow} format and vice versa.
  *
  * <p>This utility uses reflection to map fields from POJOs to InternalRow and back based on a given
- * schema. This implementation does not cache converters; getConverter creates a new instance each time.
- * types.
+ * schema. This implementation does not cache converters; getConverter creates a new instance each
+ * time. types.
  *
  * <p>Example usage:
  *
@@ -79,7 +79,6 @@
 public class ConverterUtils<T> {
     private static final Logger LOG = LoggerFactory.getLogger(ConverterUtils.class);
 
-
     /** Map of supported Java types for each DataTypeRoot. */
     private static final Map<DataTypeRoot, Set<Class<?>>> SUPPORTED_TYPES = new HashMap<>();
 
@@ -486,8 +485,7 @@ public GenericRow toRow(T pojo) {
                 throw new IllegalStateException(
                         String.format(
                                 "Failed to access field %s in POJO class %s.",
-                                rowType.getFieldNames().get(i),
-                                pojoClass.getName()),
+                                rowType.getFieldNames().get(i), pojoClass.getName()),
                         e);
             }
             row.setField(i, value);
@@ -521,8 +519,7 @@ public T fromRow(InternalRow row) {
                         throw new IllegalStateException(
                                 String.format(
                                         "Failed to set field %s in POJO class %s.",
-                                        rowType.getFieldNames().get(i),
-                                        pojoClass.getName()),
+                                        rowType.getFieldNames().get(i), pojoClass.getName()),
                                 e);
                     }
                 }
@@ -574,5 +571,4 @@ private static LinkedHashSet<Class<?>> orderedSet(Class<?>... javaTypes) {
         linkedHashSet.addAll(Arrays.asList(javaTypes));
         return linkedHashSet;
     }
-
 }

fluss-client/src/test/java/org/apache/fluss/client/utils/ConverterUtilsTest.java

@@ -30,6 +30,7 @@
 import org.apache.fluss.row.InternalRow;
 import org.apache.fluss.types.DataTypes;
 import org.apache.fluss.types.RowType;
+
 import org.junit.jupiter.api.Test;
 
 import java.math.BigDecimal;
@@ -113,8 +114,6 @@ public void testFromRow() {
         GenericRow row = converter.toRow(originalPojo);
 
         TestPojo convertedPojo = converter.fromRow(row);
-
-
         // Verify the POJO
         assertThat(convertedPojo).isNotNull();
         assertThat(convertedPojo).isEqualTo(originalPojo);
@@ -135,13 +134,13 @@ public void testNullValues() {
 
         // Verify the POJO
         assertThat(pojo).isNotNull();
-        assertThat(pojo.booleanField).isEqualTo(false); // Default value for boolean is false
-        assertThat(pojo.byteField).isEqualTo((byte) 0); // Default value for byte is 0
-        assertThat(pojo.shortField).isEqualTo((short) 0); // Default value for short is 0
-        assertThat(pojo.intField).isEqualTo(0); // Default value for int is 0
-        assertThat(pojo.longField).isEqualTo(0L); // Default value for long is 0
-        assertThat(pojo.floatField).isEqualTo(0.0f); // Default value for float is 0.0
-        assertThat(pojo.doubleField).isEqualTo(0.0); // Default value for double is 0.0
+        assertThat(pojo.booleanField).isNull();
+        assertThat(pojo.byteField).isNull();
+        assertThat(pojo.shortField).isNull();
+        assertThat(pojo.intField).isNull();
+        assertThat(pojo.longField).isNull();
+        assertThat(pojo.floatField).isNull();
+        assertThat(pojo.doubleField).isNull();
         assertThat(pojo.stringField).isNull();
         assertThat(pojo.bytesField).isNull();
         assertThat(pojo.decimalField).isNull();
@@ -209,12 +208,12 @@ public void testRowWithMissingFields() {
         assertThat(convertedPojo.booleanField).isEqualTo(true);
         assertThat(convertedPojo.intField).isEqualTo(123456);
         assertThat(convertedPojo.stringField).isEqualTo("Hello, World!");
-        // Other fields have default values
-        assertThat(convertedPojo.byteField).isEqualTo((byte) 0);
-        assertThat(convertedPojo.shortField).isEqualTo((short) 0);
-        assertThat(convertedPojo.longField).isEqualTo(0L);
-        assertThat(convertedPojo.floatField).isEqualTo(0.0f);
-        assertThat(convertedPojo.doubleField).isEqualTo(0.0);
+        // Other fields are null
+        assertThat(convertedPojo.byteField).isNull();
+        assertThat(convertedPojo.shortField).isNull();
+        assertThat(convertedPojo.longField).isNull();
+        assertThat(convertedPojo.floatField).isNull();
+        assertThat(convertedPojo.doubleField).isNull();
         assertThat(convertedPojo.bytesField).isNull();
         assertThat(convertedPojo.decimalField).isNull();
         assertThat(convertedPojo.dateField).isNull();
@@ -328,13 +327,13 @@ public void testWriteAndReadPojos() throws Exception {
 
     /** Test POJO class with various field types. */
     public static class TestPojo {
-        private boolean booleanField;
-        private byte byteField;
-        private short shortField;
-        private int intField;
-        private long longField;
-        private float floatField;
-        private double doubleField;
+        private Boolean booleanField;
+        private Byte byteField;
+        private Short shortField;
+        private Integer intField;
+        private Long longField;
+        private Float floatField;
+        private Double doubleField;
         private String stringField;
         private byte[] bytesField;
         private BigDecimal decimalField;
@@ -347,13 +346,13 @@ public static class TestPojo {
         public TestPojo() {}
 
         public TestPojo(
-                boolean booleanField,
-                byte byteField,
-                short shortField,
-                int intField,
-                long longField,
-                float floatField,
-                double doubleField,
+                Boolean booleanField,
+                Byte byteField,
+                Short shortField,
+                Integer intField,
+                Long longField,
+                Float floatField,
+                Double doubleField,
                 String stringField,
                 byte[] bytesField,
                 BigDecimal decimalField,
@@ -388,13 +387,13 @@ public boolean equals(Object o) {
                 return false;
             }
             TestPojo testPojo = (TestPojo) o;
-            return booleanField == testPojo.booleanField
-                    && byteField == testPojo.byteField
-                    && shortField == testPojo.shortField
-                    && intField == testPojo.intField
-                    && longField == testPojo.longField
-                    && Float.compare(testPojo.floatField, floatField) == 0
-                    && Double.compare(testPojo.doubleField, doubleField) == 0
+            return Objects.equals(booleanField, testPojo.booleanField)
+                    && Objects.equals(byteField, testPojo.byteField)
+                    && Objects.equals(shortField, testPojo.shortField)
+                    && Objects.equals(intField, testPojo.intField)
+                    && Objects.equals(longField, testPojo.longField)
+                    && Objects.equals(floatField, testPojo.floatField)
+                    && Objects.equals(doubleField, testPojo.doubleField)
                     && Objects.equals(stringField, testPojo.stringField)
                     && Arrays.equals(bytesField, testPojo.bytesField)
                     && Objects.equals(decimalField, testPojo.decimalField)