diff options
| author | Jeff Zhang <zjffdu@apache.org> | 2015-10-20 23:58:27 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-10-20 23:58:27 -0700 |
| commit | 5cdea7d1e54e751f928876ead33fc01e7e2f3437 (patch) | |
| tree | d31a404058fc1aa551cddaae613ce317323aafb4 /python/pyspark/sql/dataframe.py | |
| parent | 1107bd958aefc793d6e8e369ad6268b24a0f8510 (diff) | |
| download | spark-5cdea7d1e54e751f928876ead33fc01e7e2f3437.tar.gz spark-5cdea7d1e54e751f928876ead33fc01e7e2f3437.tar.bz2 spark-5cdea7d1e54e751f928876ead33fc01e7e2f3437.zip | |
[SPARK-11205][PYSPARK] Delegate to scala DataFrame API rather than p…
…rint in python
No test needed. Verify it manually in pyspark shell
Author: Jeff Zhang <zjffdu@apache.org>
Closes #9177 from zjffdu/SPARK-11205.
Diffstat (limited to 'python/pyspark/sql/dataframe.py')
| -rw-r--r-- | python/pyspark/sql/dataframe.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/python/pyspark/sql/dataframe.py b/python/pyspark/sql/dataframe.py index 033b31983f..36fc6e0611 100644 --- a/python/pyspark/sql/dataframe.py +++ b/python/pyspark/sql/dataframe.py @@ -212,6 +212,7 @@ class DataFrame(object): :param extended: boolean, default ``False``. If ``False``, prints only the physical plan. >>> df.explain() + == Physical Plan == Scan PhysicalRDD[age#0,name#1] >>> df.explain(True) @@ -227,7 +228,7 @@ class DataFrame(object): if extended: print(self._jdf.queryExecution().toString()) else: - print(self._jdf.queryExecution().executedPlan().toString()) + print(self._jdf.queryExecution().simpleString()) @since(1.3) def isLocal(self): |