Skip to content

Commit e5912f8

Browse files
committed
simplify infered filters.
1 parent 5b25fce commit e5912f8

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/optimizer/InferFiltersFromConstraintsSuite.scala

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,9 @@ class InferFiltersFromConstraintsSuite extends PlanTest {
3232
PushPredicateThroughJoin,
3333
PushDownPredicate,
3434
InferFiltersFromConstraints,
35-
CombineFilters) :: Nil
35+
CombineFilters,
36+
SimplifyBinaryComparison,
37+
BooleanSimplification) :: Nil
3638
}
3739

3840
val testRelation = LocalRelation('a.int, 'b.int, 'c.int)
@@ -169,13 +171,13 @@ class InferFiltersFromConstraintsSuite extends PlanTest {
169171
&& "t.int_col".attr === "t2.a".attr))
170172
.analyze
171173
val correctAnswer = t1.where(IsNotNull('a) && IsNotNull(Coalesce(Seq('a, 'a)))
172-
&& 'a === Coalesce(Seq('a, 'a)) && 'a <=> Coalesce(Seq('a, 'a)) && 'a <=> 'a
174+
&& 'a === Coalesce(Seq('a, 'a)) && 'a <=> Coalesce(Seq('a, 'a))
173175
&& 'a === 'b && IsNotNull(Coalesce(Seq('a, 'b))) && 'a === Coalesce(Seq('a, 'b))
174176
&& IsNotNull('b) && IsNotNull(Coalesce(Seq('b, 'b)))
175-
&& 'b === Coalesce(Seq('b, 'b)) && 'b <=> Coalesce(Seq('b, 'b)) && 'b <=> 'b)
177+
&& 'b === Coalesce(Seq('b, 'b)) && 'b <=> Coalesce(Seq('b, 'b)))
176178
.select('a, 'b.as('d), Coalesce(Seq('a, 'b)).as('int_col)).as("t")
177179
.join(t2.where(IsNotNull('a) && IsNotNull(Coalesce(Seq('a, 'a)))
178-
&& 'a === Coalesce(Seq('a, 'a)) && 'a <=> Coalesce(Seq('a, 'a)) && 'a <=> 'a), Inner,
180+
&& 'a === Coalesce(Seq('a, 'a)) && 'a <=> Coalesce(Seq('a, 'a))), Inner,
179181
Some("t.a".attr === "t2.a".attr
180182
&& "t.d".attr === "t2.a".attr
181183
&& "t.int_col".attr === "t2.a".attr))

0 commit comments

Comments
 (0)