Skip to content

Commit 5cdea7d

Browse files
zjffdurxin
authored andcommitted
[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.
1 parent 1107bd9 commit 5cdea7d

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

python/pyspark/sql/dataframe.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -212,6 +212,7 @@ def explain(self, extended=False):
212212
:param extended: boolean, default ``False``. If ``False``, prints only the physical plan.
213213
214214
>>> df.explain()
215+
== Physical Plan ==
215216
Scan PhysicalRDD[age#0,name#1]
216217
217218
>>> df.explain(True)
@@ -227,7 +228,7 @@ def explain(self, extended=False):
227228
if extended:
228229
print(self._jdf.queryExecution().toString())
229230
else:
230-
print(self._jdf.queryExecution().executedPlan().toString())
231+
print(self._jdf.queryExecution().simpleString())
231232

232233
@since(1.3)
233234
def isLocal(self):

0 commit comments

Comments
 (0)