private static Filter getRowFilter()

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;
  }