HBASE & Java: Scan Filters

(Last Updated On: )

This tutorial will guide you through how to use filtering when scanning a HBASE table using Java 8. Make sure you first follow this tutorial on connecting to HBASE and this tutorial on scanning HBase.

Row Key Filter (PrefixFilter):

  1. final PrefixFilter prefixFilter = new PrefixFilter(Bytes.toBytes(myRoKey));
  2. scan.addFilter(prefixFilter);

Column Value Filter:

  1. final SingleColumnValueFilter columnValueFilter = new SingleColumnValueFilter(myColumnFamily, myColumnName, CompareOp.EQUAL, Bytes.toBytes(myValue));
  2. scan.addFilter(columnValueFilter);

Regex Filter:

  1. final RegexStringComparator regexStringComparator = new RegexStringComparator(".*");
  2. final SingleColumnValueFilter singleColumnValueFilter = new SingleColumnValueFilter(myColumnFamily, myColumnName, CompareOp.EQUAL, regexStringComparator);
  3. scan.addFilter(singleColumnValueFilter);