rename to PojoConverterUtils

Author: polyzos

…e/fluss/client/utils/ConverterUtils.java …uss/client/utils/PojoConverterUtils.javafluss-client/src/main/java/org/apache/fluss/client/utils/ConverterUtils.java renamed to fluss-client/src/main/java/org/apache/fluss/client/utils/PojoConverterUtils.java fluss-client/src/main/java/org/apache/fluss/client/utils/ConverterUtils.java renamed to fluss-client/src/main/java/org/apache/fluss/client/utils/PojoConverterUtils.java

@@ -76,8 +76,8 @@
  *
  * @param <T> The POJO type to convert
  */
-public class ConverterUtils<T> {
-    private static final Logger LOG = LoggerFactory.getLogger(ConverterUtils.class);
+public class PojoConverterUtils<T> {
+    private static final Logger LOG = LoggerFactory.getLogger(PojoConverterUtils.class);
 
     /** Map of supported Java types for each DataTypeRoot. */
     private static final Map<DataTypeRoot, Set<Class<?>>> SUPPORTED_TYPES = new HashMap<>();
@@ -132,7 +132,7 @@ private interface RowToFieldConverter {
      * @param rowType The row schema to use for conversion
      */
     @SuppressWarnings("unchecked")
-    private ConverterUtils(Class<T> pojoClass, RowType rowType) {
+    private PojoConverterUtils(Class<T> pojoClass, RowType rowType) {
         this.pojoClass = pojoClass;
         this.rowType = rowType;
 
@@ -161,8 +161,8 @@ private ConverterUtils(Class<T> pojoClass, RowType rowType) {
      * @return A converter for the specified POJO class and row type
      */
     @SuppressWarnings("unchecked")
-    public static <T> ConverterUtils<T> getConverter(Class<T> pojoClass, RowType rowType) {
-        return new ConverterUtils<>(pojoClass, rowType);
+    public static <T> PojoConverterUtils<T> getConverter(Class<T> pojoClass, RowType rowType) {
+        return new PojoConverterUtils<>(pojoClass, rowType);
     }
 
     /** Creates field converters for converting from POJO to Row for each field in the schema. */

…uss/client/utils/ConverterUtilsTest.java …client/utils/PojoConverterUtilsTest.javafluss-client/src/test/java/org/apache/fluss/client/utils/ConverterUtilsTest.java renamed to fluss-client/src/test/java/org/apache/fluss/client/utils/PojoConverterUtilsTest.java fluss-client/src/test/java/org/apache/fluss/client/utils/ConverterUtilsTest.java renamed to fluss-client/src/test/java/org/apache/fluss/client/utils/PojoConverterUtilsTest.java

@@ -36,8 +36,8 @@
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
 
-/** Tests for {@link ConverterUtils}. */
-public class ConverterUtilsTest {
+/** Tests for {@link PojoConverterUtils}. */
+public class PojoConverterUtilsTest {
 
     private TestPojo createTestPojo() {
         return new TestPojo(
@@ -60,8 +60,8 @@ private TestPojo createTestPojo() {
 
     @Test
     public void testToRow() {
-        ConverterUtils<TestPojo> converter =
-                ConverterUtils.getConverter(TestPojo.class, createTestPojoRowType());
+        PojoConverterUtils<TestPojo> converter =
+                PojoConverterUtils.getConverter(TestPojo.class, createTestPojoRowType());
 
         TestPojo pojo = createTestPojo();
 
@@ -93,8 +93,8 @@ public void testToRow() {
 
     @Test
     public void testFromRow() {
-        ConverterUtils<TestPojo> converter =
-                ConverterUtils.getConverter(TestPojo.class, createTestPojoRowType());
+        PojoConverterUtils<TestPojo> converter =
+                PojoConverterUtils.getConverter(TestPojo.class, createTestPojoRowType());
 
         TestPojo originalPojo = createTestPojo();
 
@@ -108,8 +108,8 @@ public void testFromRow() {
 
     @Test
     public void testNullValues() {
-        ConverterUtils<TestPojo> converter =
-                ConverterUtils.getConverter(TestPojo.class, createTestPojoRowType());
+        PojoConverterUtils<TestPojo> converter =
+                PojoConverterUtils.getConverter(TestPojo.class, createTestPojoRowType());
 
         assertThat(converter.toRow(null)).isNull();
 
@@ -140,11 +140,11 @@ public void testNullValues() {
 
     @Test
     public void testCaching() {
-        ConverterUtils<TestPojo> converter1 =
-                ConverterUtils.getConverter(TestPojo.class, createTestPojoRowType());
+        PojoConverterUtils<TestPojo> converter1 =
+                PojoConverterUtils.getConverter(TestPojo.class, createTestPojoRowType());
 
-        ConverterUtils<TestPojo> converter2 =
-                ConverterUtils.getConverter(TestPojo.class, createTestPojoRowType());
+        PojoConverterUtils<TestPojo> converter2 =
+                PojoConverterUtils.getConverter(TestPojo.class, createTestPojoRowType());
 
         // As caching is removed, subsequent calls should produce new instances
         assertThat(converter2).isNotSameAs(converter1);
@@ -162,7 +162,7 @@ public void testPartialPojo() {
                         .build();
 
         // Expect an IllegalArgumentException when creating a converter with a field not in the POJO
-        assertThatThrownBy(() -> ConverterUtils.getConverter(PartialTestPojo.class, rowType))
+        assertThatThrownBy(() -> PojoConverterUtils.getConverter(PartialTestPojo.class, rowType))
                 .isInstanceOf(IllegalArgumentException.class)
                 .hasMessageContaining("Field 'extraField' not found in POJO class");
     }
@@ -177,7 +177,7 @@ public void testRowWithMissingFields() {
                         .field("stringField", DataTypes.STRING())
                         .build();
 
-        ConverterUtils<TestPojo> converter = ConverterUtils.getConverter(TestPojo.class, rowType);
+        PojoConverterUtils<TestPojo> converter = PojoConverterUtils.getConverter(TestPojo.class, rowType);
 
         TestPojo pojo = createTestPojo();
 
@@ -214,8 +214,8 @@ public void testRowWithMissingFields() {
     public void testFieldAccessFailureThrows() {
         RowType rowType = RowType.builder().field("intField", DataTypes.INT()).build();
 
-        ConverterUtils<FinalFieldPojo> converter =
-                ConverterUtils.getConverter(FinalFieldPojo.class, rowType);
+        PojoConverterUtils<FinalFieldPojo> converter =
+                PojoConverterUtils.getConverter(FinalFieldPojo.class, rowType);
 
         GenericRow row = new GenericRow(1);
         row.setField(0, 42);
@@ -230,7 +230,7 @@ public void testFieldAccessFailureThrows() {
     public void testNoDefaultConstructorPojoThrows() {
         RowType rowType = RowType.builder().field("intField", DataTypes.INT()).build();
         assertThatThrownBy(
-                () -> ConverterUtils.getConverter(NoDefaultConstructorPojo.class, rowType))
+                () -> PojoConverterUtils.getConverter(NoDefaultConstructorPojo.class, rowType))
                 .isInstanceOf(IllegalArgumentException.class)
                 .hasMessageContaining("must have a default constructor");
     }