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

sample/hadoop-0.16/tw/org/nchc/demo/DemoWordCount.java

@@ -28 +28 @@
 import org.apache.hadoop.mapred.Reducer;
 import org.apache.hadoop.mapred.Reporter;
-
-import tw.org.nchc.code.Convert;
 
 /**
@@ -107 +105 @@
     conf.setNumMapTasks(mapTasks);
     conf.setNumReduceTasks(reduceTasks);
-    //0.16
-//    conf.setInputPath(new Path(filename));
-    Convert.setInputPath(conf, new Path(filename));
+
+    conf.setInputPath(new Path(filename));
+
     conf.setOutputKeyClass(Text.class);
     conf.setOutputValueClass(IntWritable.class);
-    // 0.16
-//    conf.setOutputPath(new Path(outputPath));
-    Convert.setInputPath(conf, new Path(outputPath));
+
+    conf.setOutputPath(new Path(outputPath));
     conf.setMapperClass(MapClass.class);
     conf.setCombinerClass(ReduceClass.class);
@@ -121 +118 @@
     // Delete the output directory if it exists already
     Path outputDir = new Path(outputPath);
-    // 0.16
-//    FileSystem.get(conf).delete(outputDir);
-    FileSystem.get(conf).delete(outputDir,true);
+    FileSystem.get(conf).delete(outputDir);
     JobClient.runJob(conf);
   }