Skip to content

Commit 036dd87

Browse files
committed
fix regression
1 parent 63e4b49 commit 036dd87

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

spark/src/main/scala/org/apache/comet/serde/strings.scala

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,15 @@ import org.apache.comet.serde.ExprOuterClass.Expr
3131
import org.apache.comet.serde.QueryPlanSerde.{createBinaryExpr, exprToProtoInternal, optExprWithInfo, scalarFunctionExprToProto}
3232

3333
object CometReverse extends CometScalarFunction[Reverse]("reverse") {
34+
35+
override def getSupportLevel(expr: Reverse): SupportLevel = {
36+
if (expr.child.dataType.isInstanceOf[ArrayType]) {
37+
CometArrayReverse.getSupportLevel(expr)
38+
} else {
39+
Compatible()
40+
}
41+
}
42+
3443
override def convert(expr: Reverse, inputs: Seq[Attribute], binding: Boolean): Option[Expr] = {
3544
if (expr.child.dataType.isInstanceOf[ArrayType]) {
3645
CometArrayReverse.convert(expr, inputs, binding)

0 commit comments

Comments
 (0)