You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mahout.apache.org by dr...@apache.org on 2010/07/08 02:04:49 UTC
svn commit: r961540 -
/mahout/trunk/utils/src/main/java/org/apache/mahout/utils/nlp/collocations/llr/CollocDriver.java
Author: drew
Date: Thu Jul 8 00:04:49 2010
New Revision: 961540
URL: http://svn.apache.org/viewvc?rev=961540&view=rev
Log:
MAHOUT-167 MAHOUT-417: left out job.waitForCompletion(true) in generateCollocations method
Modified:
mahout/trunk/utils/src/main/java/org/apache/mahout/utils/nlp/collocations/llr/CollocDriver.java
Modified: mahout/trunk/utils/src/main/java/org/apache/mahout/utils/nlp/collocations/llr/CollocDriver.java
URL: http://svn.apache.org/viewvc/mahout/trunk/utils/src/main/java/org/apache/mahout/utils/nlp/collocations/llr/CollocDriver.java?rev=961540&r1=961539&r2=961540&view=diff
==============================================================================
--- mahout/trunk/utils/src/main/java/org/apache/mahout/utils/nlp/collocations/llr/CollocDriver.java (original)
+++ mahout/trunk/utils/src/main/java/org/apache/mahout/utils/nlp/collocations/llr/CollocDriver.java Thu Jul 8 00:04:49 2010
@@ -200,7 +200,7 @@ public final class CollocDriver extends
boolean emitUnigrams,
int maxNGramSize,
int reduceTasks,
- int minSupport) throws IOException {
+ int minSupport) throws IOException, ClassNotFoundException, InterruptedException {
Configuration con = new Configuration(baseConf);
con.setBoolean(EMIT_UNIGRAMS, emitUnigrams);
@@ -230,6 +230,8 @@ public final class CollocDriver extends
job.setOutputFormatClass(SequenceFileOutputFormat.class);
job.setReducerClass(CollocReducer.class);
job.setNumReduceTasks(reduceTasks);
+
+ job.waitForCompletion(true);
return job.getCounters().findCounter(CollocMapper.Count.NGRAM_TOTAL).getValue();
}