Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/22479#discussion_r219053623
--- Diff: python/pyspark/sql/tests.py ---
@@ -1168,7 +1168,7 @@ def test_simple_udt_in_df(self):
df = self.spark.createDataFrame(
[(i % 3, PythonOnlyPoint(float(i), float(i))) for i in
range(10)],
schema=schema)
- df.show()
+ df.collect()
--- End diff --
LGTM
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
