Taiwan Hadoop Forum

Configuration conf = HBaseConfiguration.create();
HTable table = new HTable(conf, TABLENAME);
Scan scan = new Scan();
scan.addColumn(Bytes.toBytes(TABLENAME), Bytes.toBytes("COLUMN"));//family name & column name
List<Filter> filters = new ArrayList<Filter>();
for(channelnum=0;channelnum<args.length-2;channelnum++){
   Filter filter[channelnum] = new ValueFilter(CompareFilter.CompareOp.EQUAL, new BinaryComparator(Bytes.toBytes(args[channelnum+2])));
   filters.add(filter[channelnum]);
}
FilterList filterlist = new FilterList(FilterList.Operator.MUST_PASS_ONE, filters);
scan.setFilter(filterlist);
ResultScanner scanner = table.getScanner(scan);
for(Result res : scanner){
   for (KeyValue kv : res.raw()) {
      System.out.println(String.format("row:%s, family:%s, qualifier:%s, qualifiervalue:%s, timestamp:%s.",
                        Bytes.toString(kv.getRow()),
                        Bytes.toString(kv.getFamily()),
                        Bytes.toString(kv.getQualifier()),
                        Bytes.toString(kv.getValue()),
                        kv.getTimestamp()));
   }
}
scanner.close();

for(channelnum=0;channelnum<args.length-2;channelnum++){
   Filter filter = new ValueFilter(CompareFilter.CompareOp.EQUAL, new BinaryComparator(Bytes.toBytes(args[channelnum+2])));
   filters.add(filter);
}