hbase-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Haijia Zhou <leons...@gmail.com>
Subject Question regarding filtering by column families
Date Tue, 06 Mar 2012 18:45:08 GMT
Hi, All

I have this question regarding filtering by column families, basically what
I am doing is to scan a table with a filter on one column family("A") and
process the data of another column family ("B") in the mapper
 my code is as follows:

        FilterList exportFilter = new
FilterList(FilterList.Operator.MUST_PASS_ONE);
        exportFilter.addFilter(new FamilyFilter(CompareOp.EQUAL, new
BinaryComparator("*A*")));

        Scan scan = new Scan();
        scan.addFamily("*B"*);
        scan.setCacheBlocks(false);
        scan.setCaching(10000);
        scan.setFilter(exportFilter);
...

Then somehow the map() method in the mapper class was never executed(The
counter "Map input records" is always 0)

If I comment out the scan.addFamily(..) line, then the map() method would
be executed.

Can someone clarify on this? Should I explicitly add column "A" to the
addFamily()?


Thanks

Haijia

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message