code: private Filter createStateFilter() {
      byte[] processedMask = new byte[Ints.BYTES * 2 + 1];
      processedMask[processedMask.length - 1] = ConsumerEntryState.PROCESSED.getState();
      return new SingleColumnValueFilter(QueueEntryRow.COLUMN_FAMILY, stateColumnName,
                                         CompareFilter.CompareOp.NOT_EQUAL,
                                         new BitComparator(processedMask, BitComparator.BitwiseOp.AND));
    }
docs: Creates a HBase filter that will filter out rows with state column state = PROCESSED (ignoring transaction).