diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala index aab3fddb4fc2a..f51c9fd5ef367 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala @@ -748,7 +748,7 @@ case class And(left: Expression, right: Expression) extends BinaryOperator with override def sqlOperator: String = "AND" - final override val nodePatterns: Seq[TreePattern] = Seq(AND_OR) + final override val nodePatterns: Seq[TreePattern] = Seq(AND) // +---------+---------+---------+---------+ // | AND | TRUE | FALSE | UNKNOWN | @@ -841,7 +841,7 @@ case class Or(left: Expression, right: Expression) extends BinaryOperator with P override def sqlOperator: String = "OR" - final override val nodePatterns: Seq[TreePattern] = Seq(AND_OR) + final override val nodePatterns: Seq[TreePattern] = Seq(OR) // +---------+---------+---------+---------+ // | OR | TRUE | FALSE | UNKNOWN | diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/expressions.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/expressions.scala index 310e3b5975700..1d756a2dcb744 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/expressions.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/expressions.scala @@ -316,9 +316,9 @@ object OptimizeIn extends Rule[LogicalPlan] { */ object BooleanSimplification extends Rule[LogicalPlan] with PredicateHelper { def apply(plan: LogicalPlan): LogicalPlan = plan.transformWithPruning( - _.containsAnyPattern(AND_OR, NOT), ruleId) { + _.containsAnyPattern(AND, OR, NOT), ruleId) { case q: LogicalPlan => q.transformExpressionsUpWithPruning( - _.containsAnyPattern(AND_OR, NOT), ruleId) { + _.containsAnyPattern(AND, OR, NOT), ruleId) { case TrueLiteral And e => e case e And TrueLiteral => e case FalseLiteral Or e => e diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/trees/TreePatterns.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/trees/TreePatterns.scala index 1a8ad7c7d6213..bf6ddca7c876a 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/trees/TreePatterns.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/trees/TreePatterns.scala @@ -25,7 +25,7 @@ object TreePattern extends Enumeration { // Expression patterns (alphabetically ordered) val AGGREGATE_EXPRESSION = Value(0) val ALIAS: Value = Value - val AND_OR: Value = Value + val AND: Value = Value val ARRAYS_ZIP: Value = Value val ATTRIBUTE_REFERENCE: Value = Value val APPEND_COLUMNS: Value = Value @@ -70,6 +70,7 @@ object TreePattern extends Enumeration { val NULL_CHECK: Value = Value val NULL_LITERAL: Value = Value val SERIALIZE_FROM_OBJECT: Value = Value + val OR: Value = Value val OUTER_REFERENCE: Value = Value val PIVOT: Value = Value val PLAN_EXPRESSION: Value = Value