Changeset 18 for sample/WordCountFromHBase.java

Timestamp:

Jul 2, 2008, 3:10:09 PM (16 years ago)

Author:

waue

Message:

upgrade 0.16 to 0.17

File:

• sample/WordCountFromHBase.java (modified) (3 diffs)

sample/WordCountFromHBase.java

@@ -3 +3 @@
  * Editor: Waue Chen 
  * From :  NCHC. Taiwn
- * Last Update Date: 06/13/2008
+ * Last Update Date: 07/02/2008
+ * Upgrade to 0.17
  */
 
@@ -25 +26 @@
 import java.util.Iterator;
 import java.util.StringTokenizer;
-import java.io.FileOutputStream;
-import java.io.File;
-import java.io.RandomAccessFile;
+
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
@@ -169 +168 @@
     // input is Hbase format => TableInputFormat
     conf.setInputFormat(TableInputFormat.class);
-    conf.setOutputPath(new Path(outputPath));
+    // 0.16
+//    conf.setOutputPath(new Path(outputPath));
+    Convert.setOutputPath(conf, new Path(outputPath));
 //     delete the old path with the same name 
-    FileSystem.get(conf).delete(new Path(outputPath));
+    FileSystem.get(conf).delete(new Path(outputPath),true);
     JobClient.runJob(conf);
   }