Changeset 25 for sample/hadoop-0.16/tw/org/nchc/code/HBaseRecordPro.java

Timestamp:

Jul 3, 2008, 4:45:54 PM (17 years ago)

Author:

waue

Message:

downgrade from 0.17 to 0.16
test for work -> not yet

File:

• sample/hadoop-0.16/tw/org/nchc/code/HBaseRecordPro.java (modified) (2 diffs)

sample/hadoop-0.16/tw/org/nchc/code/HBaseRecordPro.java

@@ -228 +228 @@
     conf.setNumMapTasks(mapTasks);
     conf.setNumReduceTasks(reduceTasks);
-    // 0.16
-//    conf.setInputPath(text_path);
-    Convert.setInputPath(conf, text_path);
+    
+    conf.setInputPath(text_path);
+
     
     conf.setMapperClass(IdentityMapper.class);
@@ -240 +240 @@
     // delete tmp file
     // 0.16
-//    FileSystem.get(conf).delete(text_path);
-    FileSystem.get(conf).delete(text_path,true);
+    FileSystem.get(conf).delete(text_path);
     
     setup.deleteFile(conf_tmp);