Changeset 27 for sample/hadoop-0.16/tw/org/nchc/demo/DemoWordCondProb.java
- Timestamp:
- Jul 3, 2008, 5:25:22 PM (17 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
sample/hadoop-0.16/tw/org/nchc/demo/DemoWordCondProb.java
r21 r27 33 33 import org.apache.hadoop.mapred.lib.IdentityReducer; 34 34 35 import tw.org.nchc.code.Convert;36 35 import tw.org.nchc.tuple.Schema; 37 36 import tw.org.nchc.tuple.Tuple; … … 185 184 conf1.setNumMapTasks(numMapTasks); 186 185 conf1.setNumReduceTasks(numReduceTasks); 187 //0.16 188 // conf1.setInputPath(new Path(inPath)); 189 Convert.setInputPath(conf1, new Path(inPath)); 186 conf1.setInputPath(new Path(inPath)); 190 187 191 188 conf1.setInputFormat(SequenceFileInputFormat.class); 192 189 193 // 0.16 194 // conf1.setOutputPath(new Path(output1Path)); 195 Convert.setOutputPath(conf1,new Path(output1Path)); 190 conf1.setOutputPath(new Path(output1Path)); 196 191 conf1.setOutputKeyClass(Tuple.class); 197 192 conf1.setOutputValueClass(FloatWritable.class);
Note: See TracChangeset
for help on using the changeset viewer.