diff --git a/.idea/workspace.xml b/.idea/workspace.xml index abf6fda..78d7982 100644 --- a/.idea/workspace.xml +++ b/.idea/workspace.xml @@ -1,17 +1,13 @@ - - - - - - + + - + @@ -39,7 +35,7 @@ - + @@ -261,10 +257,30 @@ - + - + + + + + + + + + + + + + + + + + + + + + @@ -288,7 +304,6 @@ @@ -1449,12 +1465,16 @@ 1386096004918 1386096004918 - - + @@ -1472,7 +1492,7 @@ - + @@ -1520,7 +1540,7 @@ @@ -1568,13 +1588,6 @@ - - - - - - - @@ -1614,13 +1627,6 @@ - - - - - - - @@ -1683,7 +1689,23 @@ - + + + + + + + + + + + + + + + + + diff --git a/bakemono/src/main/java/com/ontology2/bakemono/joins/SetDifferenceReducer.java b/bakemono/src/main/java/com/ontology2/bakemono/joins/SetDifferenceReducer.java index 10fc868..2aff49f 100644 --- 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 extends Reducer,VIntWritable,KeyType,NullWritable> { - final static VIntWritable ONE=new VIntWritable(1); - final static VIntWritable TWO=new VIntWritable(2); - @Override protected void reduce(TaggedItem key, Iterable values, Context context) throws IOException, InterruptedException { - Set that= Sets.newHashSet(); - Iterables.addAll(that,values); + Set 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); } }