Hbase扫描的ColumnPrefixFilter

Question

我有一个 Hbase table，列族和限定符列在下面：

maindata
content:master:909
content:master:899
content:master:97832
content:master:9902222
content:master:9
.
.
.
content:master:223343453

我需要向我的 Spark Java class 中的 Hbase Scan 对象添加一个过滤器以仅获取 content:master:anynumber 列。像 :

    Scan scan = new Scan();
    scan.addColumn(Bytes.toBytes("content"),Bytes.toBytes("master:[ *[^0-9]. *]"));

所以我只得到 content:master:anynumber 列。扫描是否支持这种模式？

Answer 1

  byte[][] prefixes = new byte[][] {Bytes.toBytes("master:")};
  Filter filter = new MultipleColumnPrefixFilter(prefixes);

  Scan scan = new Scan();
  scan.addFamily(Bytes.toBytes("content"));
  scan.setFilter(filter);

感谢 Hbase MultipleColumnPrefixFilter。

Hbase扫描的ColumnPrefixFilter

ColumnPrefixFilter for Hbase scan

apache-spark

hbase