Repository: spark Updated Branches: refs/heads/master 1107bd958 -> 5cdea7d1e
[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 <[email protected]> Closes #9177 from zjffdu/SPARK-11205. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/5cdea7d1 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/5cdea7d1 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/5cdea7d1 Branch: refs/heads/master Commit: 5cdea7d1e54e751f928876ead33fc01e7e2f3437 Parents: 1107bd9 Author: Jeff Zhang <[email protected]> Authored: Tue Oct 20 23:58:27 2015 -0700 Committer: Reynold Xin <[email protected]> Committed: Tue Oct 20 23:58:27 2015 -0700 ---------------------------------------------------------------------- python/pyspark/sql/dataframe.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/5cdea7d1/python/pyspark/sql/dataframe.py ---------------------------------------------------------------------- diff --git a/python/pyspark/sql/dataframe.py b/python/pyspark/sql/dataframe.py index 033b319..36fc6e0 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): --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
