in java/dataproc-wordcount/src/main/java/com/example/bigtable/sample/CellCounter.java [244:257]
private static Filter getRowFilter(String[] args) {
Filter rowFilter = null;
String filterCriteria = (args.length > 3) ? args[3]: null;
if (filterCriteria == null) return null;
if (filterCriteria.startsWith("^")) {
String regexPattern = filterCriteria.substring(1, filterCriteria.length());
rowFilter = new RowFilter(CompareFilter.CompareOp.EQUAL, new RegexStringComparator(regexPattern));
LOG.warn("Got the rowfilter 1: " + rowFilter);
} else {
rowFilter = new PrefixFilter(Bytes.toBytes(filterCriteria));
LOG.warn("Got the rowfilter 2: " + rowFilter);
}
return rowFilter;
}