You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mahout.apache.org by sm...@apache.org on 2014/01/27 06:25:19 UTC
svn commit: r1561586 - in
/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/classify:
ClusterClassificationDriver.java ClusterClassificationMapper.java
Author: smarthi
Date: Mon Jan 27 05:25:19 2014
New Revision: 1561586
URL: http://svn.apache.org/r1561586
Log:
MAHOUT-1410: Added Code comments.
Modified:
mahout/trunk/core/src/main/java/org/apache/mahout/clustering/classify/ClusterClassificationDriver.java
mahout/trunk/core/src/main/java/org/apache/mahout/clustering/classify/ClusterClassificationMapper.java
Modified: mahout/trunk/core/src/main/java/org/apache/mahout/clustering/classify/ClusterClassificationDriver.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/classify/ClusterClassificationDriver.java?rev=1561586&r1=1561585&r2=1561586&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/clustering/classify/ClusterClassificationDriver.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/clustering/classify/ClusterClassificationDriver.java Mon Jan 27 05:25:19 2014
@@ -202,6 +202,8 @@ public final class ClusterClassification
"part-m-" + 0), IntWritable.class, WeightedPropertyVectorWritable.class);
for (Pair<Writable, VectorWritable> vw : new SequenceFileDirIterable<Writable, VectorWritable>(input, PathType.LIST,
PathFilters.logsCRCFilter(), conf)) {
+ // Converting to NamedVectors to preserve the vectorId else its not obvious as to which point
+ // belongs to which cluster - fix for MAHOUT-1410
Writable key = vw.getFirst();
Vector vector = vw.getSecond().get();
if (!(vector instanceof NamedVector)) {
Modified: mahout/trunk/core/src/main/java/org/apache/mahout/clustering/classify/ClusterClassificationMapper.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/classify/ClusterClassificationMapper.java?rev=1561586&r1=1561585&r2=1561586&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/clustering/classify/ClusterClassificationMapper.java (original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/clustering/classify/ClusterClassificationMapper.java Mon Jan 27 05:25:19 2014
@@ -84,6 +84,8 @@ public class ClusterClassificationMapper
protected void map(WritableComparable<?> key, VectorWritable vw, Context context)
throws IOException, InterruptedException {
if (!clusterModels.isEmpty()) {
+ // Converting to NamedVectors to preserve the vectorId else its not obvious as to which point
+ // belongs to which cluster - fix for MAHOUT-1410
Vector vector = vw.get();
if (!(vector instanceof NamedVector)) {
if (key instanceof Text) {