File tree Expand file tree Collapse file tree 1 file changed +3
-4
lines changed
Expand file tree Collapse file tree 1 file changed +3
-4
lines changed Original file line number Diff line number Diff line change 11import pyarrow as pa
2- import pyarrow .compute as pc
32from datafusion import Accumulator , SessionContext , udaf
43
54
@@ -13,12 +12,12 @@ def __init__(self) -> None:
1312 self ._sum = pa .scalar (0.0 )
1413
1514 def update (self , values : pa .Array ) -> None :
16- # Not nice since pyarrow scalars can't be summed yet. This breaks on `None`
15+ # not nice since pyarrow scalars can't be summed yet. This breaks on `None`
1716 self ._sum = pa .scalar (self ._sum .as_py () + pa .compute .sum (values ).as_py ())
1817
1918 def merge (self , states : list [pa .Array ]) -> None :
20- # Not nice since pyarrow scalars can't be summed yet. This breaks on `None`
21- self ._sum = pa .scalar (self ._sum .as_py () + pa .compute .sum (states ).as_py ())
19+ # not nice since pyarrow scalars can't be summed yet. This breaks on `None`
20+ self ._sum = pa .scalar (self ._sum .as_py () + pa .compute .sum (states [ 0 ] ).as_py ())
2221
2322 def state (self ) -> list [pa .Scalar ]:
2423 return [self ._sum ]
You can’t perform that action at this time.
0 commit comments