Repository: spark Updated Branches: refs/heads/branch-1.5 03215e3e8 -> a2b0fee7b
[SQL] [MINOR] map -> foreach. DataFrame.explain should use foreach to print the explain content. Author: Reynold Xin <r...@databricks.com> Closes #8862 from rxin/map-foreach. (cherry picked from commit f3b727c801408b1cd50e5d9463f2fe0fce654a16) Signed-off-by: Andrew Or <and...@databricks.com> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/a2b0fee7 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/a2b0fee7 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/a2b0fee7 Branch: refs/heads/branch-1.5 Commit: a2b0fee7b10be27727afa599fd460ba77f620ebd Parents: 03215e3 Author: Reynold Xin <r...@databricks.com> Authored: Tue Sep 22 00:09:29 2015 -0700 Committer: Andrew Or <and...@databricks.com> Committed: Tue Sep 22 00:09:36 2015 -0700 ---------------------------------------------------------------------- sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/a2b0fee7/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala ---------------------------------------------------------------------- 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 246eaa8..49b40a3 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 --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
