Hi,
Note "double" in the function decorator. Is this specifying the type of the data that goes into pandas_mean, or the type returned by that function?
Regards,
@pandas_udf("double", PandasUDFType.GROUPED_AGG)
def pandas_mean(v):
return v.sum()
---------------------------------------------------------------------
To unsubscribe e-mail: [email protected]
