Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/20137#discussion_r159577480
--- Diff: python/pyspark/sql/udf.py ---
@@ -162,7 +168,8 @@ def wrapper(*args):
wrapper.func = self.func
wrapper.returnType = self.returnType
wrapper.evalType = self.evalType
- wrapper.asNondeterministic = self.asNondeterministic
+ wrapper.deterministic = self.deterministic
+ wrapper.asNondeterministic = lambda:
self.asNondeterministic()._wrapped()
--- End diff --
Definitely. Will give a try within the following week tho ...
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
