[Feature][transform-v2] jsonpath support map array type

CosmosNi · Jan 26, 2025 · 7fb3cc4 · 7fb3cc4
1 parent 7674aa1
commit 7fb3cc4
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 13 deletions.
diff --git a/.../src/main/java/org/apache/seatunnel/api/table/catalog/SeaTunnelDataTypeConvertorUtil.java b/.../src/main/java/org/apache/seatunnel/api/table/catalog/SeaTunnelDataTypeConvertorUtil.java
@@ -163,17 +163,17 @@ private static SeaTunnelDataType<?> parseRowType(ConfigObject conf) {
             ConfigValue typeVal = conf.get(fieldName);
             switch (typeVal.valueType()) {
                 case STRING:
-                {
-                    fieldTypes[idx] =
-                            deserializeSeaTunnelDataType(
-                                    fieldNames[idx], (String) typeVal.unwrapped());
-                }
-                break;
+                    {
+                        fieldTypes[idx] =
+                                deserializeSeaTunnelDataType(
+                                        fieldNames[idx], (String) typeVal.unwrapped());
+                    }
+                    break;
                 case OBJECT:
-                {
-                    fieldTypes[idx] = parseRowType((ConfigObject) typeVal);
-                }
-                break;
+                    {
+                        fieldTypes[idx] = parseRowType((ConfigObject) typeVal);
+                    }
+                    break;
                 case LIST:
                 case NUMBER:
                 case BOOLEAN:
@@ -248,4 +248,4 @@ private static SeaTunnelDataType<?> parseDecimalType(String columnStr) {
         int scale = Integer.parseInt(decimalInfos[1].replaceAll("\\D", ""));
         return new DecimalType(precision, scale);
     }
-}
+}
diff --git a/...-e2e-part-2/src/test/java/org/apache/seatunnel/e2e/transform/TestJsonPathTransformIT.java b/...-e2e-part-2/src/test/java/org/apache/seatunnel/e2e/transform/TestJsonPathTransformIT.java
@@ -66,4 +66,4 @@ public void testArrayType(TestContainer container) throws Exception {
                 container.executeJob("/json_path_transform/json_path_array_map.conf");
         Assertions.assertEquals(0, execResult.getExitCode());
     }
-}
+}
diff --git a/...main/java/org/apache/seatunnel/translation/spark/serialization/SeaTunnelRowConverter.java b/...main/java/org/apache/seatunnel/translation/spark/serialization/SeaTunnelRowConverter.java
@@ -301,4 +301,4 @@ private Object reconvertArray(WrappedArray.ofRef<?> arrayData, ArrayType<?, ?> a
         }
         return newArray;
     }
-}
+}
-Original file line number
+Diff line change
@@ Expand Up @@
                     container.executeJob("/json_path_transform/json_path_array_map.conf");
             Assertions.assertEquals(0, execResult.getExitCode());
         }
-    }
+    }