Author: drew
Date: Fri Jul 2 02:43:48 2010
New Revision: 959833
URL: http://svn.apache.org/viewvc?rev=959833&view=rev
Log:
MAHOUT-401: Creates NamedVectors when writing out merged vectors.
Modified:
mahout/trunk/utils/src/main/java/org/apache/mahout/utils/vectors/common/PartialVectorMergeReducer.java
Modified:
mahout/trunk/utils/src/main/java/org/apache/mahout/utils/vectors/common/PartialVectorMergeReducer.java
URL:
http://svn.apache.org/viewvc/mahout/trunk/utils/src/main/java/org/apache/mahout/utils/vectors/common/PartialVectorMergeReducer.java?rev=959833&r1=959832&r2=959833&view=diff
==============================================================================
---
mahout/trunk/utils/src/main/java/org/apache/mahout/utils/vectors/common/PartialVectorMergeReducer.java
(original)
+++
mahout/trunk/utils/src/main/java/org/apache/mahout/utils/vectors/common/PartialVectorMergeReducer.java
Fri Jul 2 02:43:48 2010
@@ -26,6 +26,7 @@ import org.apache.hadoop.mapred.MapReduc
import org.apache.hadoop.mapred.OutputCollector;
import org.apache.hadoop.mapred.Reducer;
import org.apache.hadoop.mapred.Reporter;
+import org.apache.mahout.math.NamedVector;
import org.apache.mahout.math.RandomAccessSparseVector;
import org.apache.mahout.math.SequentialAccessSparseVector;
import org.apache.mahout.math.Vector;
@@ -58,7 +59,7 @@ public class PartialVectorMergeReducer e
if (sequentialAccess) {
vector = new SequentialAccessSparseVector(vector);
}
- VectorWritable vectorWritable = new VectorWritable(vector);
+ VectorWritable vectorWritable = new VectorWritable(new NamedVector(vector,
key.toString()));
output.collect(key, vectorWritable);
}