Changes between Version 2 and Version 3 of table_example1

Timestamp:

09/14/2012 12:01:16 PM (14 years ago)

Author:

liaojiaohe

Comment:

--

table_example1

@@ -52 +52 @@
 }
 }}}
+
+进行分页查询
+{{{
+public static List<Action> getUserActions(int userid, int offset, int limit)
+throws Exception {
+  // Initialize counter and List to return
+  int count = 0;
+  List<Action> actions = new ArrayList<Action>(limit);
+ 
+  // Initialize startRow, stopRow, and columns to match
+  byte [] startRow = makeActionRow(userid,0,0);
+  byte [] stopRow = makeActionRow(userid,Long.MAX_VALUE,Integer.MAX_VALUE);
+  byte [][] columns = {Bytes.toBytes("content:name")};
+ 
+  // Open Scanner
+  HTable ht = new HTable("useractions");
+  Scanner s = ht.getScanner(columns,startRow,stopRow);
+  RowResult res = null;
+ 
+  // Iterate over Scanner
+  while((res = s.next()) != null) {
+    // Check if past offset
+    if(++count <= offset) continue;
+ 
+    // Get data from RowResult
+    byte [] row = res.getRow();
+    byte [] value = res.get(columns[0]).getValue();
+ 
+    // Build Action
+    Action action = readActionRow(row);
+    String name = Bytes.toString(value);
+    action.setName(name);
+    actions.add(action);
+ 
+    // Check limit
+    if(count == offset + limit) break;
+  }
+  // Cleanup and return
+  s.close();
+  return actions;
+}
+}}}