Author: jeastman
Date: Sat Jun 13 21:47:49 2009
New Revision: 784479
URL: http://svn.apache.org/viewvc?rev=784479&view=rev
Log:
-Fixed Vector decoding bug in DirichletMapper
Modified:
lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletMapper.java
Modified:
lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletMapper.java
URL:
http://svn.apache.org/viewvc/lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletMapper.java?rev=784479&r1=784478&r2=784479&view=diff
==============================================================================
---
lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletMapper.java
(original)
+++
lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletMapper.java
Sat Jun 13 21:47:49 2009
@@ -30,6 +30,7 @@
import org.apache.hadoop.mapred.Mapper;
import org.apache.hadoop.mapred.OutputCollector;
import org.apache.hadoop.mapred.Reporter;
+import org.apache.mahout.matrix.AbstractVector;
import org.apache.mahout.matrix.DenseVector;
import org.apache.mahout.matrix.TimesFunction;
import org.apache.mahout.matrix.Vector;
@@ -42,7 +43,7 @@
@Override
public void map(WritableComparable<?> key, Text values,
OutputCollector<Text, Text> output, Reporter reporter) throws
IOException {
- Vector v = DenseVector.decodeFormat(values.toString());
+ Vector v = AbstractVector.decodeVector(values.toString());
// compute a normalized vector of probabilities that v is described by
each model
Vector pi = normalizedProbabilities(state, v);
// then pick one model by sampling a Multinomial distribution based upon
them
