mahout-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From smar...@apache.org
Subject svn commit: r1556877 - in /mahout/trunk: CHANGELOG core/src/main/java/org/apache/mahout/clustering/streaming/mapreduce/StreamingKMeansDriver.java
Date Thu, 09 Jan 2014 17:01:55 GMT
Author: smarthi
Date: Thu Jan  9 17:01:54 2014
New Revision: 1556877

URL: http://svn.apache.org/r1556877
Log:
MAHOUT-1392: Streaming KMeans should write centroid output to a 'part-r-xxxx' file when executed
in sequential mode

Modified:
    mahout/trunk/CHANGELOG
    mahout/trunk/core/src/main/java/org/apache/mahout/clustering/streaming/mapreduce/StreamingKMeansDriver.java

Modified: mahout/trunk/CHANGELOG
URL: http://svn.apache.org/viewvc/mahout/trunk/CHANGELOG?rev=1556877&r1=1556876&r2=1556877&view=diff
==============================================================================
--- mahout/trunk/CHANGELOG (original)
+++ mahout/trunk/CHANGELOG Thu Jan  9 17:01:54 2014
@@ -2,6 +2,8 @@ Mahout Change Log
 
 Release 0.9 - unreleased
 
+  MAHOUT-1392: Streaming KMeans should write centroid output to a 'part-r-xxxx' file when
executed in sequential mode (smarthi)
+
   MAHOUT-1390: SVD hangs for certain inputs (tdunning)
 
   MAHOUT-1389: Complementary Naive Bayes Classifier not getting called when "-c" option is
activated (Gouri Shankar Majumdar via smarthi)

Modified: mahout/trunk/core/src/main/java/org/apache/mahout/clustering/streaming/mapreduce/StreamingKMeansDriver.java
URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/streaming/mapreduce/StreamingKMeansDriver.java?rev=1556877&r1=1556876&r2=1556877&view=diff
==============================================================================
--- mahout/trunk/core/src/main/java/org/apache/mahout/clustering/streaming/mapreduce/StreamingKMeansDriver.java
(original)
+++ mahout/trunk/core/src/main/java/org/apache/mahout/clustering/streaming/mapreduce/StreamingKMeansDriver.java
Thu Jan  9 17:01:54 2014
@@ -440,7 +440,7 @@ public final class StreamingKMeansDriver
     pool.shutdown();
     pool.awaitTermination(Long.MAX_VALUE, TimeUnit.SECONDS);
     log.info("Finished StreamingKMeans");
-    SequenceFile.Writer writer = SequenceFile.createWriter(FileSystem.get(conf), conf, output,
IntWritable.class,
+    SequenceFile.Writer writer = SequenceFile.createWriter(FileSystem.get(conf), conf, new
Path(output, "part-r-00000"), IntWritable.class,
         CentroidWritable.class);
     int numCentroids = 0;
     // Run BallKMeans on the intermediate centroids.



Mime
View raw message