Skip to content

Commit 37ae9b0

Browse files
committed
Address comment.
1 parent f59bb19 commit 37ae9b0

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/CodeGenerator.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -323,8 +323,7 @@ class CodegenContext {
323323
case _: StructType | _: ArrayType | _: MapType => s"$value = $initCode.copy();"
324324
case _ => s"$value = $initCode;"
325325
}
326-
ExprCode(code, FalseLiteral,
327-
GlobalValue(value, ExprType(this, dataType)))
326+
ExprCode(code, FalseLiteral, GlobalValue(value, ExprType(this, dataType)))
328327
}
329328

330329
def declareMutableStates(): String = {

sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoinExec.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ import scala.collection.mutable.ArrayBuffer
2222
import org.apache.spark.rdd.RDD
2323
import org.apache.spark.sql.catalyst.InternalRow
2424
import org.apache.spark.sql.catalyst.expressions._
25-
import org.apache.spark.sql.catalyst.expressions.codegen._
25+
import org.apache.spark.sql.catalyst.expressions.codegen.{CodegenContext, ExprCode, ExprType, FalseLiteral, VariableValue}
2626
import org.apache.spark.sql.catalyst.plans._
2727
import org.apache.spark.sql.catalyst.plans.physical._
2828
import org.apache.spark.sql.execution.{BinaryExecNode, CodegenSupport,

0 commit comments

Comments
 (0)