Skip to content

Commit 3ae3260

Browse files
committed
fix: update UDAF implementation to use correct pyarrow compute functions
1 parent 6dcb82c commit 3ae3260

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

test_udaf_script.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,11 +14,11 @@ def __init__(self) -> None:
1414

1515
def update(self, values: pa.Array) -> None:
1616
# Not nice since pyarrow scalars can't be summed yet. This breaks on `None`
17-
self._sum = pa.scalar(self._sum.as_py() + pc.sum(values).as_py())
17+
self._sum = pa.scalar(self._sum.as_py() + pa.compute.sum(values).as_py())
1818

1919
def merge(self, states: list[pa.Array]) -> None:
2020
# Not nice since pyarrow scalars can't be summed yet. This breaks on `None`
21-
self._sum = pa.scalar(self._sum.as_py() + pc.sum(states[0]).as_py())
21+
self._sum = pa.scalar(self._sum.as_py() + pa.compute.sum(states).as_py())
2222

2323
def state(self) -> list[pa.Scalar]:
2424
return [self._sum]

0 commit comments

Comments
 (0)