svn commit: r1572839 - /hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java

[edwardyoon]

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));
     }