Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- ResultScanner scanner = null;
- HTable table = null;
- Configuration config = HBaseConfiguration.create();
- config.set("hbase.zookeeper.quorum", hbaseServer);
- config.set("hbase.zookeeper.property.clientPort", hbasePort);
- FilterList list = new FilterList(FilterList.Operator.MUST_PASS_ALL);
- table = new HTable(config, "TableName");
- SingleColumnValueFilter filter = new SingleColumnValueFilter(Bytes.toBytes("ColumnName"),
- Bytes.toBytes("ColumnName"), CompareFilter.CompareOp.EQUAL,
- new BinaryComparator(Bytes.toBytes(String.valueOf("FilterValue"))));
- SingleColumnValueFilter filter1 = new SingleColumnValueFilter(Bytes.toBytes("ColumnName2"),
- Bytes.toBytes("ColumnName2"), CompareFilter.CompareOp.EQUAL,
- new BinaryComparator(Bytes.toBytes(String.valueOf("FilterValue2"))));
- list.addFilter(filter);
- list.addFilter(filter1);
- Scan scan = new Scan();
- scan.setFilter(list);
- scan.setFilter(new PageFilter(10));
- scanner = table.getScanner(scan);
- scan.setMaxResultSize(10);
- scan.setMaxResultSize(10);
Add Comment
Please, Sign In to add comment