#92 -- more logging code

paulhoule · Dec 18, 2013 · bfdfe11 · bfdfe11
1 parent e4b8bc0
commit bfdfe11
Show file tree

Hide file tree

Showing 2 changed files with 44 additions and 34 deletions.
diff --git a/.idea/workspace.xml b/.idea/workspace.xml
diff --git a/bakemono/src/main/java/com/ontology2/bakemono/entityCentric/EntityMatchesRuleReducer.java b/bakemono/src/main/java/com/ontology2/bakemono/entityCentric/EntityMatchesRuleReducer.java
@@ -3,11 +3,14 @@
 import com.google.common.collect.Lists;
 import org.apache.hadoop.io.NullWritable;
 import org.apache.hadoop.mapreduce.Reducer;
+import org.apache.log4j.Logger;
 
 import java.io.IOException;
 import java.util.List;
 
 abstract public class EntityMatchesRuleReducer<KEY,VALUE> extends Reducer<KEY,VALUE,NullWritable,VALUE> {
+    static Logger log= Logger.getLogger(EntityMatchesRuleReducer.class);
+
     @Override
     protected void reduce(KEY key,Iterable<VALUE> values,Context context) throws IOException, InterruptedException {
 
@@ -19,8 +22,12 @@ protected void reduce(KEY key,Iterable<VALUE> values,Context context) throws IOE
         //
 
         List<VALUE> rewindableValues= Lists.newArrayList();
-        for(VALUE value:values)
+        for(VALUE value:values) {
+            if (value.toString().contains("/m.01hpdw>")) {
+                log.info("Key: "+key+" has value ["+value+"]");
+            }
             rewindableValues.add(value);
+        }
 
         if(matches(key,rewindableValues)) 
             for(VALUE value:rewindableValues)