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