You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by ed...@apache.org on 2014/02/28 07:37:59 UTC
svn commit: r1572839 -
/hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java
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));
}