You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by gu...@apache.org on 2018/09/20 07:03:24 UTC
spark git commit: [MINOR][PYTHON][TEST] Use collect() instead of
show() to make the output silent
Repository: spark
Updated Branches:
refs/heads/master 0e31a6f25 -> 7ff5386ed
[MINOR][PYTHON][TEST] Use collect() instead of show() to make the output silent
## What changes were proposed in this pull request?
This PR replace an effective `show()` to `collect()` to make the output silent.
**Before:**
```
test_simple_udt_in_df (pyspark.sql.tests.SQLTests) ... +---+----------+
|key| val|
+---+----------+
| 0|[0.0, 0.0]|
| 1|[1.0, 1.0]|
| 2|[2.0, 2.0]|
| 0|[3.0, 3.0]|
| 1|[4.0, 4.0]|
| 2|[5.0, 5.0]|
| 0|[6.0, 6.0]|
| 1|[7.0, 7.0]|
| 2|[8.0, 8.0]|
| 0|[9.0, 9.0]|
+---+----------+
```
**After:**
```
test_simple_udt_in_df (pyspark.sql.tests.SQLTests) ... ok
```
## How was this patch tested?
Manually tested.
Closes #22479 from HyukjinKwon/minor-udf-test.
Authored-by: hyukjinkwon <gu...@apache.org>
Signed-off-by: hyukjinkwon <gu...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/7ff5386e
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/7ff5386e
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/7ff5386e
Branch: refs/heads/master
Commit: 7ff5386ed934190344b2cda1069bde4bc68a3e63
Parents: 0e31a6f
Author: hyukjinkwon <gu...@apache.org>
Authored: Thu Sep 20 15:03:16 2018 +0800
Committer: hyukjinkwon <gu...@apache.org>
Committed: Thu Sep 20 15:03:16 2018 +0800
----------------------------------------------------------------------
python/pyspark/sql/tests.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/7ff5386e/python/pyspark/sql/tests.py
----------------------------------------------------------------------
diff --git a/python/pyspark/sql/tests.py b/python/pyspark/sql/tests.py
index 603f994..8724bbc 100644
--- a/python/pyspark/sql/tests.py
+++ b/python/pyspark/sql/tests.py
@@ -1168,7 +1168,7 @@ class SQLTests(ReusedSQLTestCase):
df = self.spark.createDataFrame(
[(i % 3, PythonOnlyPoint(float(i), float(i))) for i in range(10)],
schema=schema)
- df.show()
+ df.collect()
def test_nested_udt_in_df(self):
schema = StructType().add("key", LongType()).add("val", ArrayType(PythonOnlyUDT()))
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org