update

Author: chenkovsky

python/datafusion/context.py

@@ -783,7 +783,7 @@ def register_parquet(
             file_extension,
             skip_metadata,
             schema,
-            [[expr.raw_sort for expr in exprs] for exprs in file_sort_order]
+            [sort_list_to_raw_sort_list(exprs) for exprs in file_sort_order]
             if file_sort_order is not None
             else None,
         )

python/datafusion/udf.py

@@ -158,7 +158,7 @@ def state(self) -> List[pyarrow.Scalar]:
         pass
 
     @abstractmethod
-    def update(self, values: pyarrow.Array) -> None:
+    def update(self, *values: pyarrow.Array) -> None:
         """Evaluate an array of values and update state."""
         pass