Changeset 28 for sample/hadoop-0.16/tw/org/nchc/demo/DemoWordCountTuple.java

Timestamp:

Jul 3, 2008, 5:40:27 PM (16 years ago)

Author:

waue

Message:

resolve 0.17 ->0.16 problem . all? not sure ! XD

File:

• sample/hadoop-0.16/tw/org/nchc/demo/DemoWordCountTuple.java (modified) (1 diff)

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

@@ -163 +163 @@
     conf.setNumReduceTasks(numReduceTasks);
     // 0.16
-    // conf.setInputPath(new Path(inPath));
-    Convert.setInputPath(conf, new Path(inPath));
+    conf.setInputPath(new Path(inPath));
     conf.setInputFormat(SequenceFileInputFormat.class);
 
-    // conf.setOutputPath(new Path(outputPath));
-    Convert.setInputPath(conf, new Path(outputPath));
+    conf.setOutputPath(new Path(outputPath));
     conf.setOutputKeyClass(Tuple.class);
     conf.setOutputValueClass(IntWritable.class);