private Filter createFilter ( ) { return new FilterList ( FilterList . Operator . MUST_PASS_ONE , processedStateFilter , new SingleColumnValueFilter ( QueueEntryRow . COLUMN_FAMILY , stateColumnName , CompareFilter . CompareOp . GREATER , new BinaryPrefixComparator ( Bytes . toBytes ( transaction . getReadPointer ( ) ) ) ) ) ; }
Creates a HBase filter that will filter out rows that that has committed state = PROCESSED .