Github user icexelloss commented on a diff in the pull request:
https://github.com/apache/spark/pull/22329#discussion_r215267320
--- Diff: python/pyspark/sql/functions.py ---
@@ -2804,6 +2804,22 @@ def pandas_udf(f=None, returnType=None,
functionType=None):
| 1|1.5|
| 2|6.0|
+---+---+
+ >>> @pandas_udf(
+ ... "id long, additional_key double, v double",
--- End diff --
do you mind changing the type of additional_key to long? It seems like the
type coercion here is not necessary.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
