Changeset 25 for sample/hadoop-0.16/tw/org/nchc/code/WordCount.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/tw/org/nchc/code/WordCount.java (modified) (2 diffs)

sample/hadoop-0.16/tw/org/nchc/code/WordCount.java

@@ -110 +110 @@
     conf.setNumMapTasks(mapTasks);
     conf.setNumReduceTasks(reduceTasks);
-    // 0.16
-    // conf.setInputPath(new Path(wc.filepath));
-    Convert.setInputPath(conf, new Path(wc.filepath));
+    
+    conf.setInputPath(new Path(wc.filepath));
+
     conf.setOutputKeyClass(Text.class);
     conf.setOutputValueClass(IntWritable.class);
-    // 0.16
-    // conf.setOutputPath(new Path(wc.outputPath));
-    Convert.setOutputPath(conf, new Path(wc.outputPath));
+
+    conf.setOutputPath(new Path(wc.outputPath));
 
     conf.setMapperClass(MapClass.class);
@@ -125 +124 @@
     // Delete the output directory if it exists already
     Path outputDir = new Path(wc.outputPath);
-    // 0.16
-    FileSystem.get(conf).delete(outputDir,true);
-
+    FileSystem.get(conf).delete(outputDir);
     JobClient.runJob(conf);
   }