Skip to content

Commit 43b9229

Browse files
committed
fix style
1 parent 3dcc184 commit 43b9229

1 file changed

Lines changed: 6 additions & 4 deletions

File tree

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

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -20,9 +20,11 @@
2020
package org.apache.comet.serde
2121

2222
import scala.annotation.tailrec
23-
import org.apache.spark.sql.catalyst.expressions.{ArrayAppend, ArrayContains, ArrayDistinct, ArrayExcept, ArrayInsert, ArrayIntersect, ArrayJoin, ArrayMax, ArrayMin, ArrayRemove, ArrayRepeat, ArrayUnion, ArraysOverlap, Attribute, CreateArray, ElementAt, Expression, Flatten, GetArrayItem, Literal, Reverse}
23+
24+
import org.apache.spark.sql.catalyst.expressions.{ArrayAppend, ArrayContains, ArrayDistinct, ArrayExcept, ArrayInsert, ArrayIntersect, ArrayJoin, ArrayMax, ArrayMin, ArrayRemove, ArrayRepeat, ArraysOverlap, ArrayUnion, Attribute, CreateArray, ElementAt, Expression, Flatten, GetArrayItem, Literal, Reverse}
2425
import org.apache.spark.sql.internal.SQLConf
2526
import org.apache.spark.sql.types._
27+
2628
import org.apache.comet.CometSparkSessionExtensions.withInfo
2729
import org.apache.comet.serde.QueryPlanSerde._
2830
import org.apache.comet.shims.CometExprShim
@@ -432,9 +434,9 @@ object CometGetArrayItem extends CometExpressionSerde[GetArrayItem] {
432434

433435
object CometArrayReverse extends CometExpressionSerde[Reverse] with ArraysBase {
434436
override def convert(
435-
expr: Reverse,
436-
inputs: Seq[Attribute],
437-
binding: Boolean): Option[ExprOuterClass.Expr] = {
437+
expr: Reverse,
438+
inputs: Seq[Attribute],
439+
binding: Boolean): Option[ExprOuterClass.Expr] = {
438440
val reverseExprProto = exprToProto(expr.child, inputs, binding)
439441
val reverseScalarExpr = scalarFunctionExprToProto("array_reverse", reverseExprProto)
440442
optExprWithInfo(reverseScalarExpr, expr, expr.children: _*)

0 commit comments

Comments
 (0)