Author: gsingers
Date: Thu Nov 3 21:04:21 2011
New Revision: 1197308
URL: http://svn.apache.org/viewvc?rev=1197308&view=rev
Log:
delete bad main()
Modified:
mahout/trunk/core/src/main/java/org/apache/mahout/classifier/bayes/mapreduce/common/BayesFeatureDriver.java
Modified:
mahout/trunk/core/src/main/java/org/apache/mahout/classifier/bayes/mapreduce/common/BayesFeatureDriver.java
URL:
http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/classifier/bayes/mapreduce/common/BayesFeatureDriver.java?rev=1197308&r1=1197307&r2=1197308&view=diff
==============================================================================
---
mahout/trunk/core/src/main/java/org/apache/mahout/classifier/bayes/mapreduce/common/BayesFeatureDriver.java
(original)
+++
mahout/trunk/core/src/main/java/org/apache/mahout/classifier/bayes/mapreduce/common/BayesFeatureDriver.java
Thu Nov 3 21:04:21 2011
@@ -17,8 +17,6 @@
package org.apache.mahout.classifier.bayes.mapreduce.common;
-import java.io.IOException;
-
import org.apache.hadoop.conf.Configurable;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.io.DoubleWritable;
@@ -31,7 +29,11 @@ import org.apache.mahout.classifier.baye
import org.apache.mahout.common.HadoopUtil;
import org.apache.mahout.common.StringTuple;
-/** Create and run the Bayes Feature Reader Step. */
+import java.io.IOException;
+
+/**
+ * Create and run the Bayes Feature Reader Step.
+ */
public class BayesFeatureDriver implements BayesJob {
@Override
@@ -45,32 +47,22 @@ public class BayesFeatureDriver implemen
conf.setOutputKeyComparatorClass(FeatureLabelComparator.class);
FileInputFormat.setInputPaths(conf, input);
FileOutputFormat.setOutputPath(conf, output);
-
+
conf.setMapperClass(BayesFeatureMapper.class);
-
+
conf.setInputFormat(KeyValueTextInputFormat.class);
conf.setCombinerClass(BayesFeatureCombiner.class);
conf.setReducerClass(BayesFeatureReducer.class);
conf.setOutputFormat(BayesFeatureOutputFormat.class);
conf.set("io.serializations",
-
"org.apache.hadoop.io.serializer.JavaSerialization,org.apache.hadoop.io.serializer.WritableSerialization");
+
"org.apache.hadoop.io.serializer.JavaSerialization,org.apache.hadoop.io.serializer.WritableSerialization");
// this conf parameter needs to be set enable serialisation of conf values
HadoopUtil.delete(conf, output);
conf.set("bayes.parameters", params.toString());
-
+
client.setConf(conf);
JobClient.runJob(conf);
-
- }
-
- public static void main(String[] args) throws IOException {
- // test harness, delete me
- BayesFeatureDriver driver = new BayesFeatureDriver();
- BayesParameters p = new BayesParameters();
- p.setGramSize(1);
- Path input = new Path("/home/drew/mahout/bayes/20news-input");
- Path output = new Path("/home/drew/mahout/bayes/20-news-features");
- driver.runJob(input, output, p);
+
}
}