Fixed runtime compilation error.

brkyvz · Jun 11, 2015 · 9a48e8d · 9a48e8d
1 parent 911c450
commit 9a48e8d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala
@@ -251,11 +251,8 @@ abstract class BinaryComparison extends BinaryExpression with Predicate {
 
   override def genCode(ctx: CodeGenContext, ev: GeneratedExpressionCode): String = {
     left.dataType match {
-      case dt: NumericType if ctx.isNativeType(dt) => defineCodeGen (ctx, ev, {
-        (c1, c3) => s"$c1 $symbol $c3"
-      })
-      case StringType =>
-        defineCodeGen (ctx, ev, (c1, c2) => s"$c1.compareTo($c2) $symbol 0")
+      case dt: NumericType if ctx.isNativeType(dt) =>
+        defineCodeGen (ctx, ev, (c1, c3) => s"$c1 $symbol $c3")
       case DateType | TimestampType =>
         defineCodeGen (ctx, ev, (c1, c3) => s"$c1 $symbol $c3")
       case _ =>

diff --git a/unsafe/src/main/java/org/apache/spark/unsafe/types/UTF8String.java b/unsafe/src/main/java/org/apache/spark/unsafe/types/UTF8String.java
@@ -182,6 +182,10 @@ public int compareTo(final UTF8String other) {
     return bytes.length - b.length;
   }
 
+  public int compare(final UTF8String other) {
+    return compareTo(other);
+  }
+
   @Override
   public boolean equals(final Object other) {
     if (other instanceof UTF8String) {