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

apache · Jan 23, 2025 · 3e077f7 · 3e077f7
1 parent e9c6285
commit 3e077f7
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/...main/java/org/apache/seatunnel/translation/spark/serialization/SeaTunnelRowConverter.java b/...main/java/org/apache/seatunnel/translation/spark/serialization/SeaTunnelRowConverter.java
@@ -24,6 +24,7 @@
 import org.apache.seatunnel.api.table.type.SeaTunnelDataType;
 import org.apache.seatunnel.api.table.type.SeaTunnelRow;
 import org.apache.seatunnel.api.table.type.SeaTunnelRowType;
+import org.apache.seatunnel.api.table.type.SqlType;
 import org.apache.seatunnel.translation.serialization.RowConverter;
 import org.apache.seatunnel.translation.spark.utils.OffsetDateTimeUtils;
 
@@ -170,6 +171,13 @@ private WrappedArray.ofRef<?> convertArray(Object[] arrayData, ArrayType<?, ?> a
             return new WrappedArray.ofRef<>(new Object[0]);
         }
         int num = arrayData.length;
+        if (SqlType.MAP.equals(arrayType.getElementType().getSqlType())) {
+            Object[] arrayMapData = new Object[num];
+            for (int i = 0; i < num; i++) {
+                arrayMapData[i] = convert(arrayData[i], arrayType.getElementType());
+            }
+            return new WrappedArray.ofRef<>(arrayMapData);
+        }
         for (int i = 0; i < num; i++) {
             arrayData[i] = convert(arrayData[i], arrayType.getElementType());
         }