You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mahout.apache.org by sr...@apache.org on 2011/08/17 11:30:09 UTC
svn commit: r1158593 -
/mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/stochasticsvd/BBtJob.java
Author: srowen
Date: Wed Aug 17 09:30:09 2011
New Revision: 1158593
URL: http://svn.apache.org/viewvc?rev=1158593&view=rev
Log:
MAHOUT-786 set num reducers to avoid overrun
Modified:
mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/stochasticsvd/BBtJob.java
Modified: mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/stochasticsvd/BBtJob.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/stochasticsvd/BBtJob.java?rev=1158593&r1=1158592&r2=1158593&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/stochasticsvd/BBtJob.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/math/hadoop/stochasticsvd/BBtJob.java Wed Aug 17 09:30:09 2011
@@ -37,9 +37,7 @@ import org.apache.mahout.math.Vector;
import org.apache.mahout.math.VectorWritable;
/**
- * Compute B*Bt using simple fact that B*Bt = sum(outer prod ( B_(*i), (B_(*i))
- * ).
- *
+ * Compute B*Bt using simple fact that B*Bt = sum(outer prod ( B_(*i), (B_(*i)) ).
*/
public final class BBtJob {
@@ -63,9 +61,10 @@ public final class BBtJob {
job.setMapOutputKeyClass(IntWritable.class);
job.setMapOutputValueClass(VectorWritable.class);
job.setMapperClass(BBtMapper.class);
- job.setReducerClass(BBtReducer.class);
// combiner and reducer
+ job.setReducerClass(BBtReducer.class);
+ job.setNumReduceTasks(numReduceTasks);
job.setOutputKeyClass(IntWritable.class);
job.setOutputValueClass(VectorWritable.class);
@@ -91,8 +90,7 @@ public final class BBtJob {
private final VectorWritable vw = new VectorWritable();
private final IntWritable iw = new IntWritable();
- private UpperTriangular bbtPartial; // are all partial BBt products
- // symmetrical as well? yes.
+ private UpperTriangular bbtPartial; // are all partial BBt products symmetrical as well? yes.
@Override
protected void map(IntWritable key, VectorWritable value, Context context)