zhengruifeng commented on code in PR #38961:
URL: https://github.com/apache/spark/pull/38961#discussion_r1041844991
##
python/pyspark/sql/tests/connect/test_connect_function.py:
##
@@ -63,6 +63,24 @@ class SparkConnectFunctionTests(SparkConnectFuncTestCase):
"""These test c
zhengruifeng commented on code in PR #38961:
URL: https://github.com/apache/spark/pull/38961#discussion_r1041844991
##
python/pyspark/sql/tests/connect/test_connect_function.py:
##
@@ -63,6 +63,24 @@ class SparkConnectFunctionTests(SparkConnectFuncTestCase):
"""These test c
zhengruifeng commented on code in PR #38961:
URL: https://github.com/apache/spark/pull/38961#discussion_r1041847513
##
python/pyspark/sql/tests/connect/test_connect_function.py:
##
@@ -413,6 +431,144 @@ def test_aggregation_functions(self):
sdf.groupBy("a").agg(SF.p
zhengruifeng commented on code in PR #38961:
URL: https://github.com/apache/spark/pull/38961#discussion_r1041844991
##
python/pyspark/sql/tests/connect/test_connect_function.py:
##
@@ -63,6 +63,24 @@ class SparkConnectFunctionTests(SparkConnectFuncTestCase):
"""These test c
zhengruifeng commented on code in PR #38961:
URL: https://github.com/apache/spark/pull/38961#discussion_r1041847513
##
python/pyspark/sql/tests/connect/test_connect_function.py:
##
@@ -413,6 +431,144 @@ def test_aggregation_functions(self):
sdf.groupBy("a").agg(SF.p