File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
sql/core/src/main/scala/org/apache/spark/sql/execution Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -217,12 +217,11 @@ case class MapElementsExec(
217
217
}
218
218
219
219
override def doConsume (ctx : CodegenContext , input : Seq [ExprCode ], row : ExprCode ): String = {
220
- val inType = if (child.output.length == 1 ) child.output(0 ).dataType else NullType
221
- val outType = outputObjAttr.dataType
222
220
val (funcClass, methodName) = func match {
223
221
case m : MapFunction [_, _] => classOf [MapFunction [_, _]] -> " call"
224
222
case _ =>
225
- (inType, outType) match {
223
+ (if (child.output.length == 1 ) child.output(0 ).dataType else NullType ,
224
+ outputObjAttr.dataType) match {
226
225
// if a pair of an argument and return types is one of specific types
227
226
// whose specialized method (apply$mc..$sp) is generated by scalac,
228
227
// Catalyst generated a direct method call to the specialized method.
You can’t perform that action at this time.
0 commit comments