File tree Expand file tree Collapse file tree 1 file changed +1
-14
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions Expand file tree Collapse file tree 1 file changed +1
-14
lines changed Original file line number Diff line number Diff line change @@ -135,20 +135,7 @@ case class LambdaFunction(
135135 override def eval (input : InternalRow ): Any = function.eval(input)
136136
137137 override def doGenCode (ctx : CodegenContext , ev : ExprCode ): ExprCode = {
138- val functionCode = function.genCode(ctx)
139-
140- if (nullable) {
141- ev.copy(code = code """
142- | ${functionCode.code}
143- |boolean ${ev.isNull} = ${functionCode.isNull};
144- | ${CodeGenerator .javaType(dataType)} ${ev.value} = ${functionCode.value};
145- """ .stripMargin)
146- } else {
147- ev.copy(code = code """
148- | ${functionCode.code}
149- | ${CodeGenerator .javaType(dataType)} ${ev.value} = ${functionCode.value};
150- """ .stripMargin, isNull = FalseLiteral )
151- }
138+ function.genCode(ctx)
152139 }
153140
154141 override protected def withNewChildrenInternal (
You can’t perform that action at this time.
0 commit comments