Github user BryanCutler commented on a diff in the pull request:
https://github.com/apache/spark/pull/18732#discussion_r142493967
--- 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 --
nit: I think it should be `wrapper.vectorized` since wrapper is a function
and it's no longer a private var
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
