Changeset 27 for sample/hadoop-0.16/tw/org/nchc/demo/DemoHBaseSink.java

Timestamp:

Jul 3, 2008, 5:25:22 PM (17 years ago)

Author:

waue

Message:

test!

File:

• sample/hadoop-0.16/tw/org/nchc/demo/DemoHBaseSink.java (modified) (3 diffs)

sample/hadoop-0.16/tw/org/nchc/demo/DemoHBaseSink.java

@@ -4 +4 @@
  * From :  NCHC. Taiwn
  * Last Update Date: 07/02/2008
- * Upgrade to 0.17
  * Re-code from : Cloud9: A MapReduce Library for Hadoop
  */
@@ -28 +27 @@
 import org.apache.hadoop.mapred.lib.IdentityMapper;
 import org.apache.hadoop.mapred.lib.IdentityReducer;
-
-import tw.org.nchc.code.Convert;
 
 /**
@@ -81 +78 @@
     conf.setNumMapTasks(mapTasks);
     conf.setNumReduceTasks(reduceTasks);
-    // 0.16
-    // conf.setInputPath(new Path(filename));
-    Convert.setInputPath(conf, new Path(filename));
-
+    conf.setInputPath(new Path(filename));
     conf.setMapperClass(IdentityMapper.class);
     conf.setCombinerClass(IdentityReducer.class);