Skip to content

Commit

Permalink
Update spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala
Browse files Browse the repository at this point in the history
Co-authored-by: Oleks V <[email protected]>
  • Loading branch information
andygrove and comphead authored Jan 29, 2025
1 parent 5c333b7 commit 1c5e992
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2386,6 +2386,7 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde with CometExprShim
}
case _: ArrayRemove => convert(CometArrayRemove)
case _: ArrayContains => convert(CometArrayContains)
// Function introduced in 3.4.0. Refer by name to provide compatibility with older Spark builds
case _ if expr.prettyName == "array_append" => convert(CometArrayAppend)
case _: ArrayIntersect => convert(CometArrayIntersect)
case _: ArrayJoin => convert(CometArrayJoin)
Expand Down

0 comments on commit 1c5e992

Please sign in to comment.