svn commit: r1209320 - /incubator/hama/trunk/yarn/src/main/java/org/apache/hama/bsp/BSPRunner.java

[ed...@apache.org]

Author: edwardyoon
Date: Fri Dec  2 00:23:05 2011
New Revision: 1209320

URL: http://svn.apache.org/viewvc?rev=1209320&view=rev
Log:
Add counters to YARN BSPRunner

Modified:
    incubator/hama/trunk/yarn/src/main/java/org/apache/hama/bsp/BSPRunner.java

Modified: incubator/hama/trunk/yarn/src/main/java/org/apache/hama/bsp/BSPRunner.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/yarn/src/main/java/org/apache/hama/bsp/BSPRunner.java?rev=1209320&r1=1209319&r2=1209320&view=diff
==============================================================================
--- incubator/hama/trunk/yarn/src/main/java/org/apache/hama/bsp/BSPRunner.java (original)
+++ incubator/hama/trunk/yarn/src/main/java/org/apache/hama/bsp/BSPRunner.java Fri Dec  2 00:23:05 2011
@@ -38,7 +38,8 @@ public class BSPRunner {
   private Configuration conf;
   private TaskAttemptID id;
   private BSPPeerImpl<?, ?, ?, ?> peer;
-
+  private Counters counters = new Counters();
+  
   @SuppressWarnings("rawtypes")
   Class<? extends BSP> bspClass;
 
@@ -72,7 +73,7 @@ public class BSPRunner {
     BSPJob job = new BSPJob(new HamaConfiguration(conf));
 
     peer = new BSPPeerImpl(job, conf, id, umbilical, port, umbilicalAddress,
-        null);
+        null, counters);
     // this is a checked cast because we can only set a class via the BSPJob
     // class which only allows derivates of BSP.
     bspClass = (Class<? extends BSP>) conf.getClassByName(conf