Author: ssc
Date: Tue Aug 27 04:34:12 2013
New Revision: 1517747
URL: http://svn.apache.org/r1517747
Log:
MAHOUT-1318 Make ToItemVectorsReducer public
Modified:
mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/preparation/ToItemVectorsReducer.java
Modified:
mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/preparation/ToItemVectorsReducer.java
URL:
http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/preparation/ToItemVectorsReducer.java?rev=1517747&r1=1517746&r2=1517747&view=diff
==============================================================================
---
mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/preparation/ToItemVectorsReducer.java
(original)
+++
mahout/trunk/core/src/main/java/org/apache/mahout/cf/taste/hadoop/preparation/ToItemVectorsReducer.java
Tue Aug 27 04:34:12 2013
@@ -23,12 +23,14 @@ import org.apache.mahout.math.VectorWrit
import java.io.IOException;
-class ToItemVectorsReducer extends
Reducer<IntWritable,VectorWritable,IntWritable,VectorWritable> {
+public class ToItemVectorsReducer extends
Reducer<IntWritable,VectorWritable,IntWritable,VectorWritable> {
private final VectorWritable merged = new VectorWritable();
+
@Override
protected void reduce(IntWritable row, Iterable<VectorWritable> vectors,
Context ctx)
throws IOException, InterruptedException {
+
merged.setWritesLaxPrecision(true);
merged.set(VectorWritable.mergeToVector(vectors.iterator()));
ctx.write(row, merged);