HBase：如何在单个扫描操作中指定多个前缀过滤器

Question

我已经使用前缀过滤器获得了给定部分行键的扫描结果：

行键示例：123_abc、456_def、789_ghi

var prefix=Bytes.toBytes("123")
var scan = new Scan(prefix)
var prefixFilter = new PrefixFilter(prefix)
scan.setFilter(prefixFilter)
var resultScanner = table.getScanner(scan)

现在，我的问题是如何指定多个前缀过滤器作为扫描操作的输入。 Result 对象应包含所有具有给定前缀的行键值的行，例如 123 或 456。

我尝试了以下使用 FilterList 方法但无法获得所需结果的答案：

Set Multiple prefix row filter to scanner hbase java

对此（在 Scala 或 Java 中）的任何帮助将不胜感激。谢谢。

Answer 1

请检查此docs of filter list 您可能没有使用正确的选项...

FilterList.Operator.MUST_PASS_ALL (AND) 或 FilterList.Operator.MUST_PASS_ONE (OR)。由于您可以使用过滤器列表 作为过滤器列表的子级，您可以创建过滤器的层次结构以 被评估。 FilterList.Operator.MUST_PASS_ALL 懒惰地评估： 只要一个过滤器不包含 KeyValue，评估就会停止。 FilterList.Operator.MUST_PASS_ONE 非懒惰地评估：所有过滤器 总是被评估。默认为 FilterList.Operator.MUST_PASS_ALL。

 /* FilterList.Operator.MUST_PASS_ALL by default */
      FilterList allFilters = new FilterList(FilterList.Operator.MUST_PASS_ONE);
      allFilters.addFilter(new PrefixFilter(Bytes.toBytes("123")));
     allFilters.addFilter(new PrefixFilter(Bytes.toBytes("456")));
     allFilters.addFilter(new PrefixFilter(Bytes.toBytes("678")));
    scan.setFilter(allFilters);

    var resultScanner = table.getScanner(scan)

点验证：

因为你已经使用了FilterList，我想你可能使用了默认的，即MUST_PASS_ALL，所有前缀条件都需要 遇到可能这就是为什么它没有给出结果。

上述代码应该可以工作。祝你好运