File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -28,16 +28,16 @@ class MyAccumulator(Accumulator):
2828 def __init__ (self ) -> None :
2929 self ._sum = pa .scalar (0.0 )
3030
31- def update (self , values : pa .Array ) -> None :
31+ def update (self , values : list [ pa .Array ] ) -> None :
3232 # not nice since pyarrow scalars can't be summed yet. This breaks on `None`
3333 self ._sum = pa .scalar (self ._sum .as_py () + pa .compute .sum (values ).as_py ())
3434
3535 def merge (self , states : pa .Array ) -> None :
3636 # not nice since pyarrow scalars can't be summed yet. This breaks on `None`
37- self ._sum = pa .scalar (self ._sum .as_py () + pa .compute .sum (states ).as_py ())
37+ self ._sum = pa .scalar (self ._sum .as_py () + pa .compute .sum (states [ 0 ] ).as_py ())
3838
39- def state (self ) -> pa .Array :
40- return pa . array ( [self ._sum . as_py ()])
39+ def state (self ) -> list [ pa .Array ] :
40+ return [self ._sum ]
4141
4242 def evaluate (self ) -> pa .Scalar :
4343 return self ._sum
You can’t perform that action at this time.
0 commit comments