跳到主要内容

82、HBase列值

HBase列值

SingleColumnValueFilter

可以使用SingleColumnValueFilter(请参阅:https://hbase.apache.org/apidocs/org/apache/hadoop/hbase/filter/SingleColumnValueFilter.html)来测试相等(如,CompareOperaor.EQUAL),不相等(如,CompareOperaor.NOT_EQUAL)的列值或者范围(例如,CompareOperaor.GREATER)。以下是一个测试列与字符串值“my value”等效的示例:

SingleColumnValueFilter filter = new SingleColumnValueFilter(
  cf,
  column,
  CompareOperaor.EQUAL,
  Bytes.toBytes("my value")
  );
scan.setFilter(filter);

ColumnValueFilter

在HBase-2.0.0版本中引入作为SingleColumnValueFilter的互补,ColumnValueFilter只获取匹配的单元格,而SingleColumnValueFilter获取匹配单元格所属的整个行(包含其他列和值)。ColumnValueFilter的构造函数的参数与SingleColumnValueFilter相同。

ColumnValueFilter filter = new ColumnValueFilter(
  cf,
  column,
  CompareOperaor.EQUAL,
  Bytes.toBytes("my value")
  );
scan.setFilter(filter);

注意:对于“equals to a family:qualifier:value”这样的简单查询,我们强烈推荐使用以下方式,而不是使用SingleColumnValueFilter或ColumnValueFilter:

Scan scan = new Scan();
scan.addColumn(Bytes.toBytes("family"), Bytes.toBytes("qualifier"));
ValueFilter vf = new ValueFilter(CompareOperator.EQUAL,
  new BinaryComparator(Bytes.toBytes("value")));
scan.setFilter(vf);
...

此扫描将限制为指定的列’family:qualifier’,避免扫描不相关的系列和列,这些列具有更好的性能,而ValueFilter是用于执行值过滤的条件。