Changeset 9 for sample/HBaseRecord.java

Timestamp:

Jun 13, 2008, 5:45:02 PM (16 years ago)

Author:

waue

Message:

comment

File:

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

sample/HBaseRecord.java

@@ -1 @@
-/*
- *  NCHC Hbase with map reduce sample code 
- *  DemoHBaseSlink.java
+/**
+ * Program: HBaseRecord.java
+ * Editor: Waue Chen 
+ * From :  NCHC. Taiwn
+ * Last Update Date: 06/01/2008
  */
 
-package tw.org.nchc.code;
-
-import java.io.IOException;
-import java.util.Iterator;
-
-import org.apache.hadoop.fs.Path;
-import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
-import org.apache.hadoop.hbase.mapred.TableReduce;
-import org.apache.hadoop.io.LongWritable;
-import org.apache.hadoop.io.MapWritable;
-import org.apache.hadoop.io.Text;
-import org.apache.hadoop.mapred.JobClient;
-import org.apache.hadoop.mapred.JobConf;
-import org.apache.hadoop.mapred.OutputCollector;
-import org.apache.hadoop.mapred.Reporter;
-import org.apache.hadoop.mapred.lib.IdentityMapper;
-import org.apache.hadoop.mapred.lib.IdentityReducer;
-
 /**
- * This sample code will put the indicate data to Hbase.
- * 1. put test.txt in t1 directory which content is 
----------------
-name:locate:years 
-waue:taiwan:1981
-shellon:taiwan:1981
----------------
- * 2. hadoop_root/$ bin/hadoop dfs -put t1 t1
- * 3. hbase_root/$ bin/hbase shell
- * 4. hql > create table t1_table("person");
- * 5. Come to Eclipse and run this code, and we will let database as that 
- t1_table -> person
-  ----------------
-  |  name | locate | years |
-  ----------------
-  | waue  | taiwan | 1981 |
-  ----------------
-  | shellon | taiwan | 1981 |
-  * 6. Go to hbase console, type : hql > select * from t1_table;
-     
+ * Purpose : 
+ *  Parse your record and then store in HBase.
+ * 
+ * HowToUse : 
+ *  Make sure Hadoop file system and Hbase are running correctly.
+ *  1. put test.txt in t1 directory which content is 
+  ---------------
+  name:locate:years 
+  waue:taiwan:1981
+  shellon:taiwan:1981
+  ---------------
+ *  2. hadoop_root/$ bin/hadoop dfs -put t1 t1
+ *  3. hbase_root/$ bin/hbase shell
+ *  4. hql > create table t1_table("person");
+ *  5. Come to Eclipse and run this code, and we will let database as that 
+  t1_table -> person
+    ----------------
+    |  name | locate | years |
+    | waue  | taiwan | 1981 |
+    | shellon | taiwan | 1981 |
+    ----------------
+ * Check Result:
+ *  Go to hbase console, type : 
+ *    hql > select * from t1_table; 
 08/06/06 12:20:48 INFO hbase.HTable: Creating scanner over t1_table starting at key 
 +-------------------------+-------------------------+-------------------------+
@@ -66 +54 @@
 +-------------------------+-------------------------+-------------------------+
 3 row(s) in set. (0.04 sec)
- **/
+ */
+
+
+
+
+package tw.org.nchc.code;
+
+import java.io.IOException;
+import java.util.Iterator;
+
+import org.apache.hadoop.fs.Path;
+import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
+import org.apache.hadoop.hbase.mapred.TableReduce;
+import org.apache.hadoop.io.LongWritable;
+import org.apache.hadoop.io.MapWritable;
+import org.apache.hadoop.io.Text;
+import org.apache.hadoop.mapred.JobClient;
+import org.apache.hadoop.mapred.JobConf;
+import org.apache.hadoop.mapred.OutputCollector;
+import org.apache.hadoop.mapred.Reporter;
+import org.apache.hadoop.mapred.lib.IdentityMapper;
+import org.apache.hadoop.mapred.lib.IdentityReducer;
+
+
 public class HBaseRecord {
 
   /* Denify parameter */
   // one column family: person; three column qualifier: name,locate,years
-  static private String  baseId1 = "person:name";
+  static private String  baseId1 ="person:name";
   static private String  baseId2 ="person:locate";
   static private String  baseId3 ="person:years";
@@ -131 +142 @@
   public static void main(String[] args) throws IOException {
     // which path of input files in Hadoop file system  
-
     
     HBaseRecord setup = new HBaseRecord();