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

Timestamp:

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

Author:

waue

Message:

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

Location:

sample/hadoop-0.16/tw/org/nchc/demo

Files:

• DemoHBaseSink.class (modified) (previous)
• DemoHBaseSource.class (modified) (previous)
• DemoWordCondProb$MapClass.class (modified) (previous)
• DemoWordCondProb$MyPartitioner.class (modified) (previous)
• DemoWordCondProb$ReduceClass.class (modified) (previous)
• DemoWordCondProb.class (modified) (previous)
• DemoWordCountTuple.class (modified) (previous)
• DemoWordCountTuple.java (modified) (1 diff)
• DemoWordCountTuple2.class (modified) (previous)
• DemoWordCountTuple2.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);

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

@@ -125 +125 @@
     
     // 0.16
-//    conf.setInputPath(new Path(inPath));
-    Convert.setInputPath(conf,new Path(inPath));
+    conf.setInputPath(new Path(inPath));
+//    Convert.setInputPath(conf,new Path(inPath));
     conf.setInputFormat(SequenceFileInputFormat.class);
     // 0.16
-//    conf.setOutputPath(new Path(outputPath));
-    Convert.setInputPath(conf, new Path(outputPath));
+    conf.setOutputPath(new Path(outputPath));
+    //    Convert.setInputPath(conf, new Path(outputPath));
+
     
     conf.setOutputKeyClass(Tuple.class);