We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 17aa150 commit 3dcc184Copy full SHA for 3dcc184
1 file changed
spark/src/main/scala/org/apache/comet/serde/arrays.scala
@@ -435,13 +435,6 @@ object CometArrayReverse extends CometExpressionSerde[Reverse] with ArraysBase {
435
expr: Reverse,
436
inputs: Seq[Attribute],
437
binding: Boolean): Option[ExprOuterClass.Expr] = {
438
- val inputTypes = expr.children.map(_.dataType).toSet
439
- for (dt <- inputTypes) {
440
- if (!isTypeSupported(dt)) {
441
- withInfo(expr, s"data type not supported: $dt")
442
- return None
443
- }
444
445
val reverseExprProto = exprToProto(expr.child, inputs, binding)
446
val reverseScalarExpr = scalarFunctionExprToProto("array_reverse", reverseExprProto)
447
optExprWithInfo(reverseScalarExpr, expr, expr.children: _*)
0 commit comments