Update Optimizer.scala

pzzs · pzzs · commit 485c61cadd3b · 2015-04-29T17:16:18.000+08:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala
@@ -171,6 +171,9 @@ object ColumnPruning extends Rule[LogicalPlan] {
 
       Project(substitutedProjection, child)
 
+    case Project(projectList, Limit(exp, child)) =>
+      Limit(exp, Project(projectList, child))
+      
     // Eliminate no-op Projects
     case Project(projectList, child) if child.output == projectList => child
   }

Original file line number	Diff line number	Diff line change
`@@ -171,6 +171,9 @@ object ColumnPruning extends Rule[LogicalPlan] {`
`171`	`171`
`172`	`172`	`Project(substitutedProjection, child)`
`173`	`173`
	`174`	`+ case Project(projectList, Limit(exp, child)) =>`
	`175`	`+ Limit(exp, Project(projectList, child))`
	`176`	`+`
`174`	`177`	`// Eliminate no-op Projects`
`175`	`178`	`case Project(projectList, child) if child.output == projectList => child`
`176`	`179`	`}`