- Timestamp:
- Jul 3, 2008, 4:45:54 PM (16 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
sample/hadoop-0.16/tw/org/nchc/code/WordCountFromHBase.java
r23 r25 168 168 // input is Hbase format => TableInputFormat 169 169 conf.setInputFormat(TableInputFormat.class); 170 // 0.16 171 // conf.setOutputPath(new Path(outputPath)); 172 Convert.setOutputPath(conf, new Path(outputPath)); 170 conf.setOutputPath(new Path(outputPath)); 173 171 // delete the old path with the same name 174 FileSystem.get(conf).delete(new Path(outputPath) ,true);172 FileSystem.get(conf).delete(new Path(outputPath)); 175 173 JobClient.runJob(conf); 176 174 }
Note: See TracChangeset
for help on using the changeset viewer.