Fixing minor bug, updating README.md and POM

caffinc · Apr 16, 2016 · fde4e58 · fde4e58
1 parent 55b50a8
commit fde4e58
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/README.md b/README.md
@@ -11,7 +11,7 @@ MongoRDD is on Bintray and Maven Central:
 	<dependency>
         <groupId>com.caffinc.sparktools</groupId>
         <artifactId>mongordd</artifactId>
-        <version>1.0.1</version>
+        <version>1.0.2</version>
     </dependency>
 
 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
@@ -6,7 +6,7 @@
 
     <groupId>com.caffinc.sparktools</groupId>
     <artifactId>mongordd</artifactId>
-    <version>1.0.1</version>
+    <version>1.0.2</version>
 
     <name>Mongo RDD</name>
     <description>MongoDB RDD for Spark</description>

diff --git 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;
         }
 
         /**