You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mahout.apache.org by dl...@apache.org on 2009/12/07 07:03:41 UTC
svn commit: r887843 -
/lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/lda/LDADriver.java
Author: dlwh
Date: Mon Dec 7 06:03:40 2009
New Revision: 887843
URL: http://svn.apache.org/viewvc?rev=887843&view=rev
Log:
Fixes MAHOUT-197
Modified:
lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/lda/LDADriver.java
Modified: lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/lda/LDADriver.java
URL: http://svn.apache.org/viewvc/lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/lda/LDADriver.java?rev=887843&r1=887842&r2=887843&view=diff
==============================================================================
--- lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/lda/LDADriver.java (original)
+++ lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/lda/LDADriver.java Mon Dec 7 06:03:40 2009
@@ -282,12 +282,11 @@
conf.set(NUM_TOPICS_KEY, Integer.toString(numTopics));
conf.set(NUM_WORDS_KEY, Integer.toString(numWords));
conf.set(TOPIC_SMOOTHING_KEY, Double.toString(topicSmoothing));
-
+
Job job = new Job(conf);
job.setOutputKeyClass(IntPairWritable.class);
job.setOutputValueClass(DoubleWritable.class);
-
FileInputFormat.addInputPaths(job, input);
Path outPath = new Path(stateOut);
FileOutputFormat.setOutputPath(job, outPath);
@@ -298,7 +297,8 @@
job.setNumReduceTasks(numReducers);
job.setOutputFormatClass(SequenceFileOutputFormat.class);
job.setInputFormatClass(SequenceFileInputFormat.class);
-
+ job.setJarByClass(LDADriver.class);
+
job.waitForCompletion(true);
return findLL(stateOut, conf);
}