hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1572839 - /hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java
Date Fri, 28 Feb 2014 06:37:59 GMT
Author: edwardyoon
Date: Fri Feb 28 06:37:59 2014
New Revision: 1572839

URL: http://svn.apache.org/r1572839
Log:
HAMA-878: PartitioningRunner.Sorter doesn't allows duplicate key

Modified:
    hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.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=1572839&r1=1572838&r2=1572839&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 Fri Feb 28 06:37:59
2014
@@ -212,10 +212,6 @@ public class PartitioningRunner extends
     }
   }
 
-  // public SortedMap<WritableComparable, KeyValuePair<Integer, KeyValuePair>>
-  // comparisonMap = new TreeMap<WritableComparable, KeyValuePair<Integer,
-  // KeyValuePair>>();
-
   @SuppressWarnings("rawtypes")
   public Map<Integer, KeyValuePair<WritableComparable, MapWritable>> candidates
= new HashMap<Integer, KeyValuePair<WritableComparable, MapWritable>>();
 
@@ -249,8 +245,6 @@ public class PartitioningRunner extends
       value = new MapWritable();
 
       readers.get(i).next(convertedKey, value);
-      // comparisonMap.put(convertedKey, new KeyValuePair(i, value));
-      // Integer, KeyValuePair<WritableComparable, MapWritable>
       candidates.put(i, new KeyValuePair(convertedKey, value));
     }
 



Mime
View raw message