Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/18906#discussion_r163831513
--- Diff: python/pyspark/sql/functions.py ---
@@ -2105,6 +2105,14 @@ def udf(f=None, returnType=StringType()):
>>> import random
>>>
Github user ptkool commented on a diff in the pull request:
https://github.com/apache/spark/pull/18906#discussion_r163828796
--- Diff: python/pyspark/sql/functions.py ---
@@ -2105,6 +2105,14 @@ def udf(f=None, returnType=StringType()):
>>> import random
>>>
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/18906#discussion_r163759284
--- Diff: python/pyspark/sql/functions.py ---
@@ -2105,6 +2105,14 @@ def udf(f=None, returnType=StringType()):
>>> import random
>>>
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/18906#discussion_r163757006
--- Diff: python/pyspark/sql/functions.py ---
@@ -2264,6 +2272,16 @@ def pandas_udf(f=None, returnType=None,
functionType=None):
...
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/18906#discussion_r163238156
--- Diff: python/pyspark/sql/udf.py ---
@@ -180,17 +182,29 @@ def wrapper(*args):
wrapper.deterministic = self.deterministic
Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/18906#discussion_r162857718
--- Diff: python/pyspark/sql/functions.py ---
@@ -2231,6 +2239,16 @@ def pandas_udf(f=None, returnType=None,
functionType=None):
... return
Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/18906#discussion_r162857996
--- Diff: python/pyspark/sql/tests.py ---
@@ -602,6 +602,30 @@ def test_non_existed_udf(self):
self.assertRaisesRegexp(AnalysisException, "Can
Github user ueshin commented on a diff in the pull request:
https://github.com/apache/spark/pull/18906#discussion_r162857704
--- Diff: python/pyspark/sql/functions.py ---
@@ -2103,6 +2103,14 @@ def udf(f=None, returnType=StringType()):
>>> import random
>>>
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/18906#discussion_r162779803
--- Diff: python/pyspark/sql/tests.py ---
@@ -597,10 +597,29 @@ def test_non_existed_udf(self):
self.assertRaisesRegexp(AnalysisException,
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/18906#discussion_r159648955
--- Diff: python/pyspark/sql/udf.py ---
@@ -163,14 +164,26 @@ def wrapper(*args):
wrapper.returnType = self.returnType
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/18906#discussion_r159415581
--- Diff: python/pyspark/sql/udf.py ---
@@ -163,14 +164,25 @@ def wrapper(*args):
wrapper.returnType = self.returnType
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/18906#discussion_r159350021
--- Diff: python/pyspark/sql/udf.py ---
@@ -17,6 +17,7 @@
"""
User-defined function related classes and functions
"""
+import copy
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/18906#discussion_r159349970
--- Diff: python/pyspark/sql/udf.py ---
@@ -174,3 +178,12 @@ def asNondeterministic(self):
"""
self._deterministic = False
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/18906#discussion_r159349251
--- Diff: python/pyspark/sql/udf.py ---
@@ -174,3 +178,12 @@ def asNondeterministic(self):
"""
self._deterministic = False
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/18906#discussion_r159349953
--- Diff: python/pyspark/sql/udf.py ---
@@ -174,3 +178,12 @@ def asNondeterministic(self):
"""
self._deterministic = False
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/18906#discussion_r158752315
--- Diff: python/pyspark/sql/tests.py ---
@@ -1,3 +1,4 @@
+
--- End diff --
Let's remove this line
---
Github user holdenk commented on a diff in the pull request:
https://github.com/apache/spark/pull/18906#discussion_r150733716
--- Diff: dev/sparktestsupport/modules.py ---
@@ -389,18 +389,6 @@ def __hash__(self):
"python/pyspark/sql"
],
17 matches
Mail list logo
