Github user icexelloss commented on a diff in the pull request:
https://github.com/apache/spark/pull/19630#discussion_r150311217
--- Diff: python/pyspark/sql/group.py ---
@@ -260,19 +259,19 @@ def wrapped(*cols):
import pandas as pd
result = func(pd.concat(cols, axis=1, keys=columns))
if not isinstance(result, pd.DataFrame):
- raise TypeError("Return type of the user-defined function
should be "
- "Pandas.DataFrame, but is
{}".format(type(result)))
+ raise TypeError('Return type of the user-defined function
should be '
--- End diff --
Reverted.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
