File tree 2 files changed +9
-3
lines changed
2 files changed +9
-3
lines changed Original file line number Diff line number Diff line change @@ -1532,3 +1532,10 @@ def visit_ArrayRemove(op, **kw):
1532
1532
arg = translate (op .arg , ** kw )
1533
1533
value = _literal_value (op .other )
1534
1534
return arg .list .set_difference (pl .lit ([value ]))
1535
+
1536
+
1537
+ @translate .register (ops .ArrayUnion )
1538
+ def visit_ArrayUnion (op , ** kw ):
1539
+ left = translate (op .left , ** kw )
1540
+ right = translate (op .right , ** kw )
1541
+ return left .list .set_union (right )
Original file line number Diff line number Diff line change @@ -832,7 +832,6 @@ def test_array_sort(con, data):
832
832
833
833
834
834
@builtin_array
835
- @pytest .mark .notimpl (["polars" ], raises = com .OperationNotDefinedError )
836
835
@pytest .mark .parametrize (
837
836
("a" , "b" , "expected_array" ),
838
837
[
@@ -853,9 +852,9 @@ def test_array_sort(con, data):
853
852
reason = "BigQuery doesn't support arrays with null elements" ,
854
853
),
855
854
pytest .mark .notyet (
856
- ["datafusion" ],
855
+ ["datafusion" , "polars" ],
857
856
raises = AssertionError ,
858
- reason = "DataFusion transforms null elements to NAN " ,
857
+ reason = "Null elements are transformed to NaN " ,
859
858
),
860
859
pytest .mark .notyet (
861
860
["pyspark" ],
You can’t perform that action at this time.
0 commit comments