Add transformers for JSON object processing

Author: kesmit13

.gitignore

@@ -99,3 +99,4 @@ dask-worker-space
 singlestoredb/mysql/tests/databases.json
 
 trees
+CODIFI_**

AC_PLAN.md

@@ -254,7 +254,7 @@ def load_arrow(
 
 
 def dump(
-    returns: List[Tuple[int, Optional[Transformer]]],
+    returns: List[Tuple[str, int, Optional[Transformer]]],
     row_ids: List[int],
     rows: List[List[Any]],
 ) -> bytes:
@@ -263,7 +263,7 @@ def dump(
 
     Parameters
     ----------
-    returns : List[Tuple[int, Optional[Transformer]]]
+    returns : List[Tuple[str, int, Optional[Transformer]]]
         The returned data type
     row_ids : List[int]
         The row IDs
@@ -290,7 +290,7 @@ def dump(
         for i, value in enumerate(row):
             processed_row.append(
                 apply_transformer(
-                    returns[i][1], value,
+                    returns[i][2], value,
                 ),
             )
         processed_rows.append(processed_row)
@@ -307,7 +307,7 @@ def dump(
 
 
 def _dump_vectors(
-    returns: List[Tuple[int, Optional[Transformer]]],
+    returns: List[Tuple[str, int, Optional[Transformer]]],
     row_ids: 'pa.Array[pa.int64]',
     cols: List[Tuple['pa.Array[Any]', Optional['pa.Array[pa.bool_]']]],
 ) -> bytes:
@@ -316,7 +316,7 @@ def _dump_vectors(
 
     Parameters
     ----------
-    returns : List[Tuple[int, Optional[Transformer]]]
+    returns : List[Tuple[str, int, Optional[Transformer]]]
         The returned data type
     row_ids : List[int]
         The row IDs
@@ -339,7 +339,7 @@ def _dump_vectors(
     for i, (data, mask) in enumerate(cols):
         processed_cols.append((
             apply_transformer(
-                returns[i][1], data,
+                returns[i][2], data,
             ), mask,
         ))
 
@@ -358,7 +358,7 @@ def _dump_vectors(
 
 
 def dump_arrow(
-    returns: List[Tuple[int, Optional[Transformer]]],
+    returns: List[Tuple[str, int, Optional[Transformer]]],
     row_ids: 'pa.Array[int]',
     cols: List[Tuple['pa.Array[Any]', 'pa.Array[bool]']],
 ) -> bytes:
@@ -369,7 +369,7 @@ def dump_arrow(
 
 
 def dump_numpy(
-    returns: List[Tuple[int, Optional[Transformer]]],
+    returns: List[Tuple[str, int, Optional[Transformer]]],
     row_ids: 'np.typing.NDArray[np.int64]',
     cols: List[Tuple['np.typing.NDArray[Any]', 'np.typing.NDArray[np.bool_]']],
 ) -> bytes:
@@ -384,7 +384,7 @@ def dump_numpy(
 
 
 def dump_pandas(
-    returns: List[Tuple[int, Optional[Transformer]]],
+    returns: List[Tuple[str, int, Optional[Transformer]]],
     row_ids: 'pd.Series[np.int64]',
     cols: List[Tuple['pd.Series[Any]', 'pd.Series[np.bool_]']],
 ) -> bytes:
@@ -399,7 +399,7 @@ def dump_pandas(
 
 
 def dump_polars(
-    returns: List[Tuple[int, Optional[Transformer]]],
+    returns: List[Tuple[str, int, Optional[Transformer]]],
     row_ids: 'pl.Series[pl.Int64]',
     cols: List[Tuple['pl.Series[Any]', 'pl.Series[pl.Boolean]']],
 ) -> bytes: