Github user BryanCutler commented on a diff in the pull request:
https://github.com/apache/spark/pull/20295#discussion_r172374978
--- Diff: python/pyspark/worker.py ---
@@ -91,10 +92,16 @@ def verify_result_length(*a):
def wrap_grouped_map_pandas_udf(f, return_type):
- def wrapped(*series):
+ def wrapped(key_series, value_series):
import pandas as pd
+ argspec = inspect.getargspec(f)
--- End diff --
should this also do `getfullargspec` for py3 like in udf.py?
maybe it would be useful to put a function in util.py, what do you guys
think?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
