Changes between Initial Version and Version 1 of hbase/devproblem

Timestamp:

11/27/2012 10:08:33 AM (13 years ago)

Author:

liaojiaohe

Comment:

--

hbase/devproblem

@@ +1 @@
+开发的时候发现HBASE使用的一个问题
+
+
+{{{
+ byte[][] qualifiers = new byte[][]{Bytes.toBytes("apns"), Bytes.toBytes("receive_type"), Bytes.toBytes("receiv
+e_time")};
+    Scan scan = new Scan();
+    scan.setCaching(100);
+    scan.setMaxVersions(1);
+    FilterList filters = new FilterList();
+
+    RowFilter rowfilter = new RowFilter(CompareOp.EQUAL, new BinaryPrefixComparator(new String(3 + "_").getBytes()
+));
+    filters.addFilter(rowfilter);
+
+    SingleColumnValueFilter filter = new SingleColumnValueFilter(
+            Bytes.toBytes("base"),
+            "app_ver_int".getBytes(),
+            CompareOp.EQUAL,
+            Bytes.toBytes(3020000));
+    filters.addFilter(filter);
+
+    for (int i = 0; i < qualifiers.length; i++) {
+        scan.addColumn(Bytes.toBytes("base"), qualifiers[i]);
+    }
+    // filters.addFilter(new FirstKeyOnlyFilter());
+
+    scan.setFilter(filters);
+    ResultScanner scanner = hTable.getScanner(scan);
+
+}}}
+
+出现问题，由于filter里面的字段在addColumn的时候是没用的，filter就失效了