Skip to content

Commit 36c194e

Browse files
committed
Update Optimizer.scala
1 parent 2e8f6ca commit 36c194e

File tree

1 file changed

+4
-6
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer

1 file changed

+4
-6
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala

+4-6
Original file line numberDiff line numberDiff line change
@@ -294,12 +294,10 @@ object ConstantFolding extends Rule[LogicalPlan] {
294294
case e if e.foldable => Literal.create(e.eval(null), e.dataType)
295295

296296
// Fold "literal in (item1, item2, ..., literal, ...)" into true or false directly.
297-
case In(Literal(v, _), list) =>
298-
val isExists = list.exists {
299-
case Literal(candidate, _) if candidate == v => true
300-
case _ => false
301-
}
302-
if (isExists) Literal.create(true, BooleanType) else Literal.create(false, BooleanType)
297+
case InSet(Literal(v, _), hSet) => {
298+
val isExists = hSet.contains(v)
299+
if(isExists) Literal.create(true, BooleanType) else Literal.create(false, BooleanType)
300+
}
303301
}
304302
}
305303
}

0 commit comments

Comments
 (0)