Github user BryanCutler commented on a diff in the pull request:
https://github.com/apache/spark/pull/20237#discussion_r161114987
--- Diff: python/pyspark/sql/functions.py ---
@@ -2184,6 +2184,11 @@ def pandas_udf(f=None, returnType=None,
functionType=None):
| 8| JOHN DOE| 22|
+----------+--------------+------------+
+ .. note:: The length of `pandas.Series` within a scalar UDF is not
of the whole input column
+ but of the batch internally used, and it is called for each
batch. Therefore,
+ this can be used, for example, to ensure the length of each
returned `pandas.Series`
+ but should not be used as the length of the whole input.
--- End diff --
How does this sound? "..`pandas.Series`, and can not be used as the column
length"
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
