hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1242637 [2/2] - in /incubator/hama/trunk: ./ core/src/main/java/org/apache/hama/bsp/ core/src/main/java/org/apache/hama/bsp/message/ core/src/test/java/org/apache/hama/bsp/ core/src/test/java/org/apache/hama/bsp/message/ core/src/test/java...
Date Fri, 10 Feb 2012 02:06:11 GMT
Modified: incubator/hama/trunk/yarn/src/main/java/org/apache/hama/bsp/YarnSerializePrinting.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/yarn/src/main/java/org/apache/hama/bsp/YarnSerializePrinting.java?rev=1242637&r1=1242636&r2=1242637&view=diff
==============================================================================
--- incubator/hama/trunk/yarn/src/main/java/org/apache/hama/bsp/YarnSerializePrinting.java
(original)
+++ incubator/hama/trunk/yarn/src/main/java/org/apache/hama/bsp/YarnSerializePrinting.java
Fri Feb 10 02:06:10 2012
@@ -29,7 +29,7 @@ import org.apache.hama.bsp.sync.SyncExce
 public class YarnSerializePrinting {
 
   public static class HelloBSP extends
-      BSP<NullWritable, NullWritable, NullWritable, NullWritable> {
+      BSP<NullWritable, NullWritable, NullWritable, NullWritable, NullWritable> {
     public static final Log LOG = LogFactory.getLog(HelloBSP.class);
     private Configuration conf;
     private final static int PRINT_INTERVAL = 1000;
@@ -37,7 +37,7 @@ public class YarnSerializePrinting {
 
     @Override
     public void bsp(
-        BSPPeer<NullWritable, NullWritable, NullWritable, NullWritable> bspPeer)
+        BSPPeer<NullWritable, NullWritable, NullWritable, NullWritable, NullWritable>
bspPeer)
         throws IOException, SyncException, InterruptedException {
       num = conf.getInt("bsp.peers.num", 0);
       LOG.info(bspPeer.getAllPeerNames());



Mime
View raw message