From fde4e581561e982c466434fcdca5a8b6a798a524 Mon Sep 17 00:00:00 2001 From: Sriram Keerthi Madhava Kunjathur Date: Sat, 16 Apr 2016 17:41:04 +0530 Subject: [PATCH] Fixing minor bug, updating README.md and POM --- README.md | 2 +- mongordd/pom.xml | 2 +- .../main/java/com/caffinc/sparktools/mongordd/MongoRDD.java | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/README.md b/README.md index 1eb1025..61bc68c 100644 --- a/README.md +++ b/README.md @@ -11,7 +11,7 @@ MongoRDD is on Bintray and Maven Central: com.caffinc.sparktools mongordd - 1.0.1 + 1.0.2 MongoRDD extends the Spark RDD class and provides a way to read from MongoDB directly into Spark. diff --git a/mongordd/pom.xml b/mongordd/pom.xml index 0d34319..99677fa 100644 --- a/mongordd/pom.xml +++ b/mongordd/pom.xml @@ -6,7 +6,7 @@ com.caffinc.sparktools mongordd - 1.0.1 + 1.0.2 Mongo RDD MongoDB RDD for Spark diff --git a/mongordd/src/main/java/com/caffinc/sparktools/mongordd/MongoRDD.java b/mongordd/src/main/java/com/caffinc/sparktools/mongordd/MongoRDD.java index d5354ce..c67b74a 100644 --- a/mongordd/src/main/java/com/caffinc/sparktools/mongordd/MongoRDD.java +++ b/mongordd/src/main/java/com/caffinc/sparktools/mongordd/MongoRDD.java @@ -121,7 +121,7 @@ public Document next() { * * @author Sriram */ - private class MongoMapPartition implements Partition { + private static class MongoMapPartition implements Partition { private static final long serialVersionUID = 1L; private int index; private int from; @@ -157,7 +157,7 @@ public int index() { */ @Override public boolean equals(Object obj) { - return (obj instanceof MongoMapPartition) && ((MongoMapPartition) obj).index != index; + return (obj instanceof MongoMapPartition) && ((MongoMapPartition) obj).index == index; } /**