Changeset 18 for sample/HBaseRecordPro.java

Timestamp:

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

Author:

waue

Message:

upgrade 0.16 to 0.17

File:

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

sample/HBaseRecordPro.java

@@ -1 +1 @@
 /**
- * Program: HBaseRecord.java
+ * Program: HBaseRecordPro.java
  * Editor: Waue Chen 
  * From :  NCHC. Taiwn
- * Last Update Date: 06/01/2008
+ * Last Update Date: 07/02/2008
+ * Upgrade to 0.17
  */
 
@@ -227 +228 @@
     conf.setNumMapTasks(mapTasks);
     conf.setNumReduceTasks(reduceTasks);
-    conf.setInputPath(text_path);
+    // 0.16
+//    conf.setInputPath(text_path);
+    Convert.setInputPath(conf, text_path);
+    
     conf.setMapperClass(IdentityMapper.class);
     conf.setCombinerClass(IdentityReducer.class);
@@ -235 +239 @@
     
     // delete tmp file
-    FileSystem.get(conf).delete(text_path);
+    // 0.16
+//    FileSystem.get(conf).delete(text_path);
+    FileSystem.get(conf).delete(text_path,true);
+    
     setup.deleteFile(conf_tmp);
   }