You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mx...@apache.org on 2015/07/15 15:53:56 UTC
flink git commit: [FLINK-2229] Add equals() and hashCode() to
ObjectArrayTypeInfo
Repository: flink
Updated Branches:
refs/heads/release-0.9 451eb8245 -> c7e868416
[FLINK-2229] Add equals() and hashCode() to ObjectArrayTypeInfo
This closes #842.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c7e86841
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c7e86841
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c7e86841
Branch: refs/heads/release-0.9
Commit: c7e868416a5b8f61489a221ad3822dea1366d887
Parents: 451eb82
Author: Sebastian Kruse <se...@hpi.de>
Authored: Tue Jun 16 10:47:18 2015 +0200
Committer: Maximilian Michels <mx...@apache.org>
Committed: Wed Jul 15 15:53:43 2015 +0200
----------------------------------------------------------------------
.../api/java/typeutils/ObjectArrayTypeInfo.java | 18 ++++++++++++++++++
1 file changed, 18 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/c7e86841/flink-java/src/main/java/org/apache/flink/api/java/typeutils/ObjectArrayTypeInfo.java
----------------------------------------------------------------------
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/typeutils/ObjectArrayTypeInfo.java b/flink-java/src/main/java/org/apache/flink/api/java/typeutils/ObjectArrayTypeInfo.java
index 76e1d2a..6806122 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/typeutils/ObjectArrayTypeInfo.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/typeutils/ObjectArrayTypeInfo.java
@@ -127,6 +127,24 @@ public class ObjectArrayTypeInfo<T, C> extends TypeInformation<T> {
return this.getClass().getSimpleName() + "<" + this.componentInfo + ">";
}
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+
+ ObjectArrayTypeInfo<?, ?> that = (ObjectArrayTypeInfo<?, ?>) o;
+ return this.arrayType.equals(that.arrayType) && this.componentType.equals(that.componentType);
+ }
+
+ @Override
+ public int hashCode() {
+ return 31 * this.arrayType.hashCode() + this.componentType.hashCode();
+ }
+
// --------------------------------------------------------------------------------------------
public static <T, C> ObjectArrayTypeInfo<T, C> getInfoFor(Type type, TypeInformation<C> componentInfo) {