File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
catalyst/src/main/scala/org/apache/spark/sql/catalyst/planning
core/src/main/scala/org/apache/spark/sql Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -51,9 +51,9 @@ abstract class QueryPlanner[PhysicalPlan <: TreeNode[PhysicalPlan]] {
5151 * filled in automatically by the QueryPlanner using the other execution strategies that are
5252 * available.
5353 */
54- protected def planLater (plan : LogicalPlan ) = apply (plan).next()
54+ protected def planLater (plan : LogicalPlan ) = execute (plan).next()
5555
56- def apply (plan : LogicalPlan ): Iterator [PhysicalPlan ] = {
56+ def execute (plan : LogicalPlan ): Iterator [PhysicalPlan ] = {
5757 // Obviously a lot to do here still...
5858 val iter = strategies.view.flatMap(_(plan)).toIterator
5959 assert(iter.hasNext, s " No plan for $plan" )
Original file line number Diff line number Diff line change @@ -1321,7 +1321,7 @@ class SQLContext(@transient val sparkContext: SparkContext)
13211321 // TODO: Don't just pick the first one...
13221322 lazy val sparkPlan : SparkPlan = {
13231323 SparkPlan .currentContext.set(self)
1324- planner(optimizedPlan).next()
1324+ planner.execute (optimizedPlan).next()
13251325 }
13261326 // executedPlan should not be used to initialize any SparkPlan. It should be
13271327 // only used for execution.
You can’t perform that action at this time.
0 commit comments