HBase列值

2018-05-17 11:38 更新

HBase列值

SingleColumnValueFilter

可以使用SingleColumnValueFilter(請(qǐng)參閱:https://hbase.apache.org/apidocs/org/apache/hadoop/hbase/filter/SingleColumnValueFilter.html)來測試相等(如,CompareOperaor.EQUAL),不相等(如,CompareOperaor.NOT_EQUAL)的列值或者范圍(例如,CompareOperaor.GREATER)。以下是一個(gè)測試列與字符串值“my value”等效的示例:

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

ColumnValueFilter

在HBase-2.0.0版本中引入作為SingleColumnValueFilter的互補(bǔ),ColumnValueFilter只獲取匹配的單元格,而SingleColumnValueFilter獲取匹配單元格所屬的整個(gè)行(包含其他列和值)。ColumnValueFilter的構(gòu)造函數(shù)的參數(shù)與SingleColumnValueFilter相同。

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

注意:對(duì)于“equals to a family:qualifier:value”這樣的簡單查詢,我們強(qiáng)烈推薦使用以下方式,而不是使用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',避免掃描不相關(guān)的系列和列,這些列具有更好的性能,而ValueFilter是用于執(zhí)行值過濾的條件。

以上內(nèi)容是否對(duì)您有幫助:
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號(hào)
微信公眾號(hào)

編程獅公眾號(hào)