Skip to content

Commit 99fc139

Browse files
author
Davies Liu
committed
Merge branch 'enable_codegen' of github.com:davies/spark into enable_codegen
Conflicts: sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/CodeGenerator.scala
2 parents 91fc7a2 + 207e339 commit 99fc139

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/arithmetic.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -349,7 +349,7 @@ case class MaxOf(left: Expression, right: Expression) extends BinaryArithmetic {
349349
override def genCode(ctx: CodeGenContext, ev: GeneratedExpressionCode): String = {
350350
val eval1 = left.gen(ctx)
351351
val eval2 = right.gen(ctx)
352-
val compCode = ctx.genCmop(dataType, eval1.primitive, eval2.primitive)
352+
val compCode = ctx.genComp(dataType, eval1.primitive, eval2.primitive)
353353

354354
eval1.code + eval2.code + s"""
355355
boolean ${ev.isNull} = false;
@@ -401,7 +401,7 @@ case class MinOf(left: Expression, right: Expression) extends BinaryArithmetic {
401401
override def genCode(ctx: CodeGenContext, ev: GeneratedExpressionCode): String = {
402402
val eval1 = left.gen(ctx)
403403
val eval2 = right.gen(ctx)
404-
val compCode = ctx.genCmop(dataType, eval1.primitive, eval2.primitive)
404+
val compCode = ctx.genComp(dataType, eval1.primitive, eval2.primitive)
405405

406406
eval1.code + eval2.code + s"""
407407
boolean ${ev.isNull} = false;

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -159,7 +159,7 @@ class CodeGenContext {
159159
}
160160

161161
/**
162-
* Returns a function to generate equal expression in Java
162+
* Generate code for equal expression in Java
163163
*/
164164
def genEqual(dataType: DataType, c1: String, c2: String): String = dataType match {
165165
case BinaryType => s"java.util.Arrays.equals($c1, $c2)"
@@ -169,9 +169,9 @@ class CodeGenContext {
169169
}
170170

171171
/**
172-
* Return a function to generate compare expression in Java
172+
* Generate code for compare expression in Java
173173
*/
174-
def genCmop(dataType: DataType, c1: String, c2: String): String = dataType match {
174+
def genComp(dataType: DataType, c1: String, c2: String): String = dataType match {
175175
case BinaryType => s"org.apache.spark.sql.catalyst.util.TypeUtils.compareBinary($c1, $c2)"
176176
case IntegerType | LongType | DoubleType | FloatType | ShortType | ByteType | DateType =>
177177
s"$c1 - $c2"

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -251,7 +251,7 @@ abstract class BinaryComparison extends BinaryExpression with Predicate {
251251

252252
override def genCode(ctx: CodeGenContext, ev: GeneratedExpressionCode): String = {
253253
defineCodeGen(ctx, ev, {
254-
(c1, c2) => s"${ctx.genCmop(left.dataType, c1, c2)} $symbol 0"
254+
(c1, c2) => s"${ctx.genComp(left.dataType, c1, c2)} $symbol 0"
255255
})
256256
}
257257

0 commit comments

Comments
 (0)