Changeset 25 for sample/hadoop-0.16/WordCount2.java

Timestamp:

Jul 3, 2008, 4:45:54 PM (16 years ago)

Author:

waue

Message:

downgrade from 0.17 to 0.16
test for work -> not yet

File:

• sample/hadoop-0.16/WordCount2.java (modified) (3 diffs)

sample/hadoop-0.16/WordCount2.java

@@ -14 +14 @@
 import org.apache.hadoop.io.LongWritable;
 import org.apache.hadoop.io.Text;
-import org.apache.hadoop.mapred.FileInputFormat;
-import org.apache.hadoop.mapred.FileOutputFormat;
 import org.apache.hadoop.mapred.JobClient;
 import org.apache.hadoop.mapred.JobConf;
@@ -131 +129 @@
     conf.setNumReduceTasks(reduceTasks);
 
-//    conf.setInputPath(new Path(filename));
-    FileInputFormat.setInputPaths(conf,new Path(filename));
+    conf.setInputPath(new Path(filename));
+
     conf.setOutputKeyClass(Text.class);
     conf.setOutputValueClass(IntWritable.class);
     
-//    conf.setOutputPath(new Path(outputPath));
-    FileOutputFormat.setOutputPath( conf, new Path(filename));
+    conf.setOutputPath(new Path(outputPath));
+
 
 
@@ -146 +144 @@
     // Delete the output directory if it exists already
     Path outputDir = new Path(outputPath);
-    FileSystem.get(conf).delete(outputDir,true);
+    FileSystem.get(conf).delete(outputDir);
     JobClient.runJob(conf);
   }