Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/20288#discussion_r161965369
--- Diff: python/pyspark/sql/session.py ---
@@ -778,6 +778,146 @@ def __exit__(self, exc_type, exc_val, exc_tb):
self.stop()
+class UDFRegistration(object):
+ """Wrapper for user-defined function registration."""
+
+ def __init__(self, sparkSession):
+ self.sparkSession = sparkSession
+
+ @ignore_unicode_prefix
+ def register(self, name, f, returnType=None):
--- End diff --
shall we add `since 2.3`?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
