Skip to content

Commit 207e339

Browse files
author
Davies Liu
committed
Update CodeGenerator.scala
1 parent 44573a3 commit 207e339

File tree

1 file changed

+10
-12
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen

1 file changed

+10
-12
lines changed

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

Lines changed: 10 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -162,27 +162,25 @@ class CodeGenContext {
162162
* Returns a function to generate equal expression in Java
163163
*/
164164
def equalFunc(dataType: DataType): ((String, String) => String) = dataType match {
165-
case BinaryType => { case (eval1, eval2) =>
166-
s"java.util.Arrays.equals($eval1, $eval2)" }
165+
case BinaryType =>
166+
(eval1, eval2) => s"java.util.Arrays.equals($eval1, $eval2)"
167167
case IntegerType | BooleanType | LongType | DoubleType | FloatType | ShortType | ByteType
168168
| DateType =>
169-
{ case (eval1, eval2) => s"$eval1 == $eval2" }
169+
(eval1, eval2) => s"$eval1 == $eval2"
170170
case other =>
171-
{ case (eval1, eval2) => s"$eval1.equals($eval2)" }
171+
(eval1, eval2) => s"$eval1.equals($eval2)"
172172
}
173173

174174
/**
175175
* Return a function to generate compare expression in Java
176176
*/
177177
def compFunc(dataType: DataType): (String, String) => String = dataType match {
178-
case BinaryType => {
179-
case (c1, c2) =>
180-
s"org.apache.spark.sql.catalyst.util.TypeUtils.compareBinary($c1, $c2)"
181-
}
182-
case IntegerType | LongType | DoubleType | FloatType | ShortType | ByteType | DateType => {
183-
case (c1, c2) => s"$c1 - $c2"
184-
}
185-
case other => { case (c1, c2) => s"$c1.compare($c2)" }
178+
case BinaryType =>
179+
(c1, c2) => s"org.apache.spark.sql.catalyst.util.TypeUtils.compareBinary($c1, $c2)"
180+
case IntegerType | LongType | DoubleType | FloatType | ShortType | ByteType | DateType =>
181+
(c1, c2) => s"$c1 - $c2"
182+
case other =>
183+
(c1, c2) => s"$c1.compare($c2)"
186184
}
187185

188186
/**

0 commit comments

Comments
 (0)