aboutsummaryrefslogtreecommitdiff
path: root/unsafe
diff options
context:
space:
mode:
authorDavies Liu <davies@databricks.com>2015-06-23 11:55:47 -0700
committerMichael Armbrust <michael@databricks.com>2015-06-23 11:55:47 -0700
commit6f4cadf5ee81467d077febc53d36571dd232295d (patch)
treef5886b0ed4c10a4f7338ef73c128aced4f6d77cb /unsafe
parent7b1450b666f88452e7fe969a6d59e8b24842ea39 (diff)
downloadspark-6f4cadf5ee81467d077febc53d36571dd232295d.tar.gz
spark-6f4cadf5ee81467d077febc53d36571dd232295d.tar.bz2
spark-6f4cadf5ee81467d077febc53d36571dd232295d.zip
[SPARK-8432] [SQL] fix hashCode() and equals() of BinaryType in Row
Also added more tests in LiteralExpressionSuite Author: Davies Liu <davies@databricks.com> Closes #6876 from davies/fix_hashcode and squashes the following commits: 429c2c0 [Davies Liu] Merge branch 'master' of github.com:apache/spark into fix_hashcode 32d9811 [Davies Liu] fix test a0626ed [Davies Liu] Merge branch 'master' of github.com:apache/spark into fix_hashcode 89c2432 [Davies Liu] fix style bd20780 [Davies Liu] check with catalyst types 41caec6 [Davies Liu] change for to while d96929b [Davies Liu] address comment 6ad2a90 [Davies Liu] fix style 5819d33 [Davies Liu] unify equals() and hashCode() 0fff25d [Davies Liu] fix style 53c38b1 [Davies Liu] fix hashCode() and equals() of BinaryType in Row
Diffstat (limited to 'unsafe')
-rw-r--r--unsafe/src/main/java/org/apache/spark/unsafe/types/UTF8String.java6
-rw-r--r--unsafe/src/test/java/org/apache/spark/unsafe/types/UTF8StringSuite.java2
2 files changed, 1 insertions, 7 deletions
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
index 9871a70a40..9302b47292 100644
--- a/unsafe/src/main/java/org/apache/spark/unsafe/types/UTF8String.java
+++ b/unsafe/src/main/java/org/apache/spark/unsafe/types/UTF8String.java
@@ -17,10 +17,10 @@
package org.apache.spark.unsafe.types;
+import javax.annotation.Nonnull;
import java.io.Serializable;
import java.io.UnsupportedEncodingException;
import java.util.Arrays;
-import javax.annotation.Nonnull;
import org.apache.spark.unsafe.PlatformDependent;
@@ -202,10 +202,6 @@ public final class UTF8String implements Comparable<UTF8String>, Serializable {
public boolean equals(final Object other) {
if (other instanceof UTF8String) {
return Arrays.equals(bytes, ((UTF8String) other).getBytes());
- } else if (other instanceof String) {
- // Used only in unit tests.
- String s = (String) other;
- return bytes.length >= s.length() && length() == s.length() && toString().equals(s);
} else {
return false;
}
diff --git a/unsafe/src/test/java/org/apache/spark/unsafe/types/UTF8StringSuite.java b/unsafe/src/test/java/org/apache/spark/unsafe/types/UTF8StringSuite.java
index 80c179a1b5..796cdc9dbe 100644
--- a/unsafe/src/test/java/org/apache/spark/unsafe/types/UTF8StringSuite.java
+++ b/unsafe/src/test/java/org/apache/spark/unsafe/types/UTF8StringSuite.java
@@ -28,8 +28,6 @@ public class UTF8StringSuite {
Assert.assertEquals(UTF8String.fromString(str).length(), len);
Assert.assertEquals(UTF8String.fromBytes(str.getBytes("utf8")).length(), len);
- Assert.assertEquals(UTF8String.fromString(str), str);
- Assert.assertEquals(UTF8String.fromBytes(str.getBytes("utf8")), str);
Assert.assertEquals(UTF8String.fromString(str).toString(), str);
Assert.assertEquals(UTF8String.fromBytes(str.getBytes("utf8")).toString(), str);
Assert.assertEquals(UTF8String.fromBytes(str.getBytes("utf8")), UTF8String.fromString(str));