Skip to content
Closed
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Merge branch 'master' into sqlctx-refactoring
Conflicts:
	sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala
  • Loading branch information
evacchi committed May 15, 2015
commit 095355d5e3e90487ddea305fac907da3fd10afe3
24 changes: 12 additions & 12 deletions sql/core/src/main/scala/org/apache/spark/sql/SQLContext.scala
Original file line number Diff line number Diff line change
Expand Up @@ -1313,7 +1313,7 @@ protected[sql] class QueryExecution(val sqlContext: SQLContext, val logical: Log
// TODO: Don't just pick the first one...
lazy val sparkPlan: SparkPlan = {
SparkPlan.currentContext.set(sqlContext)
sqlContext.planner(optimizedPlan).next()
sqlContext.planner.plan(optimizedPlan).next()
}
// executedPlan should not be used to initialize any SparkPlan. It should be
// only used for execution.
Expand All @@ -1337,7 +1337,7 @@ protected[sql] class QueryExecution(val sqlContext: SQLContext, val logical: Log
def simpleString: String =
s"""== Physical Plan ==
|${stringOrError(executedPlan)}
""".stripMargin.trim
""".stripMargin.trim

override def toString: String = {
def output =
Expand All @@ -1348,16 +1348,16 @@ protected[sql] class QueryExecution(val sqlContext: SQLContext, val logical: Log
// We need to think about how to avoid the side effect.
s"""== Parsed Logical Plan ==
|${stringOrError(logical)}
|== Analyzed Logical Plan ==
|${stringOrError(output)}
|${stringOrError(analyzed)}
|== Optimized Logical Plan ==
|${stringOrError(optimizedPlan)}
|== Physical Plan ==
|${stringOrError(executedPlan)}
|Code Generation: ${stringOrError(executedPlan.codegenEnabled)}
|== RDD ==
""".stripMargin.trim
|== Analyzed Logical Plan ==
|${stringOrError(output)}
|${stringOrError(analyzed)}
|== Optimized Logical Plan ==
|${stringOrError(optimizedPlan)}
|== Physical Plan ==
|${stringOrError(executedPlan)}
|Code Generation: ${stringOrError(executedPlan.codegenEnabled)}
|== RDD ==
""".stripMargin.trim
}
}

Expand Down
You are viewing a condensed version of this merge commit. You can view the full changes here.