diff options
| author | Reynold Xin <rxin@databricks.com> | 2015-09-22 00:09:29 -0700 |
|---|---|---|
| committer | Andrew Or <andrew@databricks.com> | 2015-09-22 00:09:29 -0700 |
| commit | f3b727c801408b1cd50e5d9463f2fe0fce654a16 (patch) | |
| tree | ddccf3463ba2f09f3cccba20c71f7c149bd7d9f0 /sql | |
| parent | 4da32bc0e747fefe847bffe493785d4d16069c04 (diff) | |
| download | spark-f3b727c801408b1cd50e5d9463f2fe0fce654a16.tar.gz spark-f3b727c801408b1cd50e5d9463f2fe0fce654a16.tar.bz2 spark-f3b727c801408b1cd50e5d9463f2fe0fce654a16.zip | |
[SQL] [MINOR] map -> foreach.
DataFrame.explain should use foreach to print the explain content.
Author: Reynold Xin <rxin@databricks.com>
Closes #8862 from rxin/map-foreach.
Diffstat (limited to 'sql')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala b/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala index ba94d77b2e..a11140b717 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala @@ -320,9 +320,8 @@ class DataFrame private[sql]( * @since 1.3.0 */ def explain(extended: Boolean): Unit = { - ExplainCommand( - queryExecution.logical, - extended = extended).queryExecution.executedPlan.executeCollect().map { + val explain = ExplainCommand(queryExecution.logical, extended = extended) + explain.queryExecution.executedPlan.executeCollect().foreach { // scalastyle:off println r => println(r.getString(0)) // scalastyle:on println |