java - 使用HBase API(Java)使用过滤器进行扫描

Question

我想创建一个过滤器以仅返回包含给定字段(或许多字段)的行。
我的代码:

FilterList flMaster = new FilterList(FilterList.Operator.MUST_PASS_ALL);
Filter filter = new SingleColumnValueFilter(Bytes.toBytes(CF1), Bytes.toBytes("RONAME"), CompareFilter.CompareOp.EQUAL, Bytes.toBytes("roname1"));

scan.setFilter(flMaster);
scan.addFamily(Bytes.toBytes(CF1));
scan.addFamily(Bytes.toBytes(CF2));

ResultScanner resultScanner = table.getScanner(scan);

我创建了2条记录roname1和roname2。

问题是过滤器不起作用:我得到了所有行(roname1和roname2)。

有关信息:hbase版本:1.0.0

谢谢。

Answer 1

Filter filter = new ValueFilter(
        CompareFilter.CompareOp.EQUAL,
        new BinaryComparator(Bytes.toBytes("roman1")));
scan.setFilter(filter);