Github user icexelloss commented on a diff in the pull request:
https://github.com/apache/spark/pull/18732#discussion_r142499092
--- Diff: python/pyspark/sql/functions.py ---
@@ -2120,6 +2120,7 @@ def wrapper(*args):
else self.func.__class__.__module__)
wrapper.func = self.func
wrapper.returnType = self.returnType
+ wrapper._vectorized = self._vectorized
--- End diff --
Fixed.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
