hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1679358 - in /hama/trunk/core/src: main/java/org/apache/hama/bsp/PartitioningRunner.java test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java
Date Thu, 14 May 2015 12:47:44 GMT
Author: edwardyoon
Date: Thu May 14 12:47:44 2015
New Revision: 1679358

URL: http://svn.apache.org/r1679358
Log: (empty)

Modified:
    hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java
    hama/trunk/core/src/test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java

Modified: hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java?rev=1679358&r1=1679357&r2=1679358&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java (original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java Thu May 14 12:47:44
2015
@@ -143,6 +143,8 @@ public class PartitioningRunner extends
 
       raw = new MapWritable();
       raw.put(rawRecord.getKey(), rawRecord.getValue());
+      
+      System.out.println(peer.getPeerName(index) + ", " + rawRecord.getKey() + ", " + rawRecord.getValue());
       peer.send(peer.getPeerName(index), raw);
     }
 

Modified: hama/trunk/core/src/test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java?rev=1679358&r1=1679357&r2=1679358&view=diff
==============================================================================
--- hama/trunk/core/src/test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java (original)
+++ hama/trunk/core/src/test/java/org/apache/hama/bsp/TestKeyValueTextInputFormat.java Thu
May 14 12:47:44 2015
@@ -79,7 +79,6 @@ public class TestKeyValueTextInputFormat
         int expectedPeerId = Math.abs(key.hashCode() % numTasks);
 
         System.out.println(peer.getPeerName() + ": " + key + ", " + value + ", " + expectedPeerId);
-        
         /*
         if (expectedPeerId == peer.getPeerIndex()) {
           expectedKeys.put(new Text(key), new Text(value));



Mime
View raw message