HBase条件查询

最近用Hbase做了一些事情，这里记录一下使用的方法，但是没有经过性能测试。。。

HBase只提供了行级索引，因此，要进行条件查询只有两种方式：

（1）.设计合适的行键（通过行键直接定位到数据所在的位置）；

（2）.通过Scan方式进行查询，Scan可设置其实行和结束行，把这个搜索限定在一个区域中进行；

Scan可以设置一个或多个Filter，来对行键、列族和列进行过滤，从而达到条件查询的目的。

这里记录了一下使用第二种方式进行条件查询的代码。

1.RowPrefixFilter

这个filter可根据行键的前缀进行查询，即若行键满足我们设置的前缀，则会被检索出来。Hbase存储的数据是根据行键排序的，因此，根据行键的前缀来查询应该性能上会好一点，因为在Scan的源码中看到如下这一段，它把Scan的查询限制在了一定范围。

[mw_shl_code=bash,true]/**
   * <p>Set a filter (using stopRow and startRow) so the result set only contains rows where the
   * rowKey starts with the specified prefix.</p>
   * <p>This is a utility method that converts the desired rowPrefix into the appropriate values
   * for the startRow and stopRow to achieve the desired result.</p>
   * <p>This can safely be used in combination with setFilter.</p>
   * <p><b>NOTE: Doing a {@link #setStartRow(byte[])} and/or {@link #setStopRow(byte[])}
   * after this method will yield undefined results.</b></p>
   * @param rowPrefix the prefix all rows must start with. (Set <i>null</i> to remove the filter.)
   * @return this
   */
  public Scan setRowPrefixFilter(byte[] rowPrefix) {
    if (rowPrefix == null) {
      setStartRow(HConstants.EMPTY_START_ROW);
      setStopRow(HConstants.EMPTY_END_ROW);
    } else {
      this.setStartRow(rowPrefix);
      this.setStopRow(calculateTheClosestNextRowKeyForPrefix(rowPrefix));
    }
    return this;
  }[/mw_shl_code]

调用的方式也特别简单，如下：

[mw_shl_code=bash,true]scan.setRowPrefixFilter(Bytes.toBytes(value));[/mw_shl_code]

2.PageFilter
这个Filter可以帮助我们来对查询结果进行分页，每次返回一定量的结果。它的调用方式如下：

[mw_shl_code=bash,true]if (startRow != null) {
                        scan.setStartRow(startRow);
                }
filter = new PageFilter(pageSize);
scan.setFilter(filter);[/mw_shl_code]

可以在每次查询时缓存下最后一行，然后下一次查询的startRow从这一行开始，以达到分页的效果。

3.SingleColumnValueFilter
这个filter可以根据要求来筛选family:qualifier对应的value值，调用方式如下：


[mw_shl_code=bash,true]filter = new SingleColumnValueFilter(Bytes.toBytes(fam), Bytes.toBytes(qualifier),
                                                        CompareFilter.CompareOp.EQUAL, Bytes.toBytes(value));[/mw_shl_code]

使用这个Filter感觉上比较慢，但是没有具体测过，因为HBase只对Rowkey进行索引，所以猜想过去这个filter应该是对全表进行了一次查询吧，所以速度比较慢。

4.RowFilter
这个Filter是对行键进行过滤的，也可以通过它来筛选出行键中包含指定字符串的一系列行，这个功能的调用方式如下：


上面代码的item.getValue()即是行键中要包含的字符串。

5.FilterList
当有很多filter需要一起使用时，可以使用FilterList，可将许多Filter组成的ArrayList传给它的构造函数，来实例化这样一个对象，使用方法如下：

[mw_shl_code=bash,true]filter = new FilterList(FilterList.Operator.MUST_PASS_ALL, filterlist);[/mw_shl_code]

FilterList.Operator.MUST_PASS_ALL，相当于每个filter是与的关系；
FilterList.Operator.MUST_PASS_ONE，相当于是或的关系；