Changes between Version 1 and Version 2 of table_example1

Timestamp:

09/14/2012 11:56:52 AM (14 years ago)

Author:

liaojiaohe

Comment:

--

table_example1

@@ -8 +8 @@
 }}}
 
-如果采用HBASE设计，ROW设计为<userid><reverse_order_stamp><actionid>
+如果采用HBASE设计，ROW设计为<userid><reverse_order_stamp><actionid>[[BR]]
+之所以采用row-per-action而不是row-per-user,主要考虑采用row自身的索引进行查询[[BR]]
+
+{{{
+public static byte [] makeActionRow(int userid, long stamp, int actionid)
+throws Exception {
+  byte [] useridBytes = Bytes.toBytes(userid);
+  byte [] stampBytes = Bytes.toBytes(stamp);
+  byte [] actionidBytes = Bytes.toBytes(actionid);
+  return Bytes.add(useridBytes, stampBytes, actionidBytes);
+}
+
+public static Action readActionRow(byte [] row)
+throws Exception {
+  // Bytes.toInt(byte [] buf, int offset, int length)
+  int userid = Bytes.toInt(row,0,4);
+  long stamp = Long.MAX_VALUE - Bytes.toLong(row,4,8);
+  int actionid = Bytes.toInt(row,12,4);
+  return new Action(userid,stamp,actionid);
+}
+}}}
+
+插入操作
+{{{
+
+public static void putUserAction(Action action) throws Exception {
+  // Get the fields from the Action object
+  int userid = action.getUserID();
+  long stamp = Long.MAX_VALUE - action.getStamp();
+  int actionid = action.getID();
+  String name = action.getName();
+ 
+  // Build the composite row, column, and value
+  byte [] row = makeActionRow(userid,stamp,actionid);
+  byte [] column = Bytes.toBytes("content:name");
+  byte [] value = Bytes.toBytes(name);
+ 
+  // Insert to HBase
+  HTable ht = new HTable("useractions");
+  BatchUpdate bu = new BatchUpdate(row);
+  bu.put(column,value)
+  ht.commit(bu);
+}
+}}}