Skip to content

Commit 7796f19

Browse files
authored
KE-37052 translate boolean column to V2Predicate (apache#477)
1 parent 0553594 commit 7796f19

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

sql/core/src/main/scala/org/apache/spark/sql/catalyst/util/V2ExpressionBuilder.scala

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -56,8 +56,12 @@ class V2ExpressionBuilder(
5656
} else {
5757
Some(FieldReference(name))
5858
}
59-
case pushableColumn(name) if !nestedPredicatePushdownEnabled =>
60-
Some(FieldReference(name))
59+
case col @ pushableColumn(name) if !nestedPredicatePushdownEnabled =>
60+
if (isPredicate && col.dataType.isInstanceOf[BooleanType]) {
61+
Some(new V2Predicate("=", Array(FieldReference(name), LiteralValue(true, BooleanType))))
62+
} else {
63+
Some(FieldReference(name))
64+
}
6165
case in @ InSet(child, hset) =>
6266
generateExpression(child).map { v =>
6367
val children =

0 commit comments

Comments
 (0)