resolve #82 use Integer instead of VIntWritable in hash tables in old…

… SetDifference operator because this was problematic for rdfDiff
paulhoule · Dec 4, 2013 · 4b8554d · 4b8554d
1 parent 2d5529e
commit 4b8554d
Show file tree

Hide file tree

Showing 2 changed files with 57 additions and 37 deletions.
diff --git a/.idea/workspace.xml b/.idea/workspace.xml
diff --git a/bakemono/src/main/java/com/ontology2/bakemono/joins/SetDifferenceReducer.java b/bakemono/src/main/java/com/ontology2/bakemono/joins/SetDifferenceReducer.java
@@ -24,15 +24,13 @@
 public class SetDifferenceReducer<KeyType extends WritableComparable>
         extends Reducer<TaggedItem<KeyType>,VIntWritable,KeyType,NullWritable> {
 
-    final static VIntWritable ONE=new VIntWritable(1);
-    final static VIntWritable TWO=new VIntWritable(2);
-
     @Override
     protected void reduce(TaggedItem<KeyType> key, Iterable<VIntWritable> values, Context context) throws IOException, InterruptedException {
-        Set<VIntWritable> that= Sets.newHashSet();
-        Iterables.addAll(that,values);
+        Set<Integer> that= Sets.newHashSet();
+        for(VIntWritable tag:values)
+            that.add(tag.get());
 
-        if(that.contains(ONE) & !that.contains(TWO)) {
+        if(that.contains(1) & !that.contains(2)) {
             context.write(key.getKey(),null);
         }
     }