We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 485c61c commit dc83ae9Copy full SHA for dc83ae9
sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/optimizer/FilterPushdownSuite.scala
@@ -90,7 +90,23 @@ class FilterPushdownSuite extends PlanTest {
90
91
comparePlans(optimized, correctAnswer)
92
}
93
+
94
+ test("column pruning for Project(ne, Limit)") {
95
+ val originalQuery =
96
+ testRelation
97
+ .select('a,'b)
98
+ .limit(2)
99
+ .select('a)
100
101
+ val optimized = Optimize(originalQuery.analyze)
102
+ val correctAnswer =
103
104
105
+ .limit(2).analyze
106
107
+ comparePlans(optimized, correctAnswer)
108
+ }
109
110
// After this line is unimplemented.
111
test("simple push down") {
112
val originalQuery =
0 commit comments