File tree Expand file tree Collapse file tree
spark/src/main/scala/org/apache/comet/serde Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -126,8 +126,7 @@ object QueryPlanSerde extends Logging with CometExprShim {
126126 classOf [MapKeys ] -> CometMapKeys ,
127127 classOf [MapEntries ] -> CometMapEntries ,
128128 classOf [MapValues ] -> CometMapValues ,
129- classOf [MapFromArrays ] -> CometMapFromArrays ,
130- classOf [MapSort ] -> CometMapSort )
129+ classOf [MapFromArrays ] -> CometMapFromArrays )
131130
132131 private val structExpressions : Map [Class [_ <: Expression ], CometExpressionSerde [_]] = Map (
133132 classOf [CreateNamedStruct ] -> CometCreateNamedStruct ,
Original file line number Diff line number Diff line change 2020package org .apache .comet .serde
2121
2222import org .apache .spark .sql .catalyst .expressions ._
23- import org .apache .spark .sql .catalyst .expressions .objects .RowOrdering
2423import org .apache .spark .sql .types .{ArrayType , MapType }
2524
2625import org .apache .comet .CometSparkSessionExtensions .withInfo
@@ -91,21 +90,3 @@ object CometMapFromArrays extends CometExpressionSerde[MapFromArrays] {
9190 optExprWithInfo(mapFromArraysExpr, expr, expr.children: _* )
9291 }
9392}
94-
95- object CometMapSort extends CometExpressionSerde [MapSort ] {
96-
97- override def convert (
98- expr : MapSort ,
99- inputs : Seq [Attribute ],
100- binding : Boolean ): Option [ExprOuterClass .Expr ] = {
101- val keyType = expr.base.dataType.asInstanceOf [MapType ].keyType
102- if (! RowOrdering .isOrderable(keyType)) {
103- withInfo(expr, s " map_sort requires orderable key type, got: $keyType" )
104- return None
105- }
106-
107- val childExpr = exprToProtoInternal(expr.base, inputs, binding)
108- val mapSortScalarExpr = scalarFunctionExprToProto(" map_sort" , childExpr)
109- optExprWithInfo(mapSortScalarExpr, expr, expr.children: _* )
110- }
111- }
You can’t perform that action at this time.
0 commit comments