Changeset 18 for sample/HBaseRecord2.java

Timestamp:

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

Author:

waue

Message:

upgrade 0.16 to 0.17

File:

• sample/HBaseRecord2.java (modified) (4 diffs)

sample/HBaseRecord2.java

@@ -3 +3 @@
  * Editor: Waue Chen 
  * From :  NCHC. Taiwn
- * Last Update Date: 06/01/2008
+ * Last Update Date: 07/01/2008
+ * Upgrade to 0.17
  */
 
@@ -53 +54 @@
 package tw.org.nchc.code;
 
-import java.io.FileInputStream;
 import java.io.IOException;
 import java.util.Iterator;
@@ -140 +140 @@
           + "\" has already existed !");
     }
-    FileInputStream fi = new FileInputStream(setup.file_path);
-    
     
     JobConf conf = new JobConf(HBaseRecord2.class);
@@ -154 +152 @@
     conf.setNumMapTasks(setup.mapTasks);
     conf.setNumReduceTasks(setup.reduceTasks);
-    conf.setInputPath(new Path(setup.file_path));
+    // 0.16
+//    conf.setInputPath(new Path(setup.file_path));
+    Convert.setInputPath(conf, new Path(setup.file_path));
     conf.setMapperClass(IdentityMapper.class);
     conf.setCombinerClass(IdentityReducer.class);