Guest User

Untitled

a guest
Mar 19th, 2018
101
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.13 KB | None | 0 0
  1. ResultScanner scanner = null;
  2. HTable table = null;
  3. Configuration config = HBaseConfiguration.create();
  4. config.set("hbase.zookeeper.quorum", hbaseServer);
  5. config.set("hbase.zookeeper.property.clientPort", hbasePort);
  6. FilterList list = new FilterList(FilterList.Operator.MUST_PASS_ALL);
  7. table = new HTable(config, "TableName");
  8. SingleColumnValueFilter filter = new SingleColumnValueFilter(Bytes.toBytes("ColumnName"),
  9. Bytes.toBytes("ColumnName"), CompareFilter.CompareOp.EQUAL,
  10. new BinaryComparator(Bytes.toBytes(String.valueOf("FilterValue"))));
  11. SingleColumnValueFilter filter1 = new SingleColumnValueFilter(Bytes.toBytes("ColumnName2"),
  12. Bytes.toBytes("ColumnName2"), CompareFilter.CompareOp.EQUAL,
  13. new BinaryComparator(Bytes.toBytes(String.valueOf("FilterValue2"))));
  14. list.addFilter(filter);
  15. list.addFilter(filter1);
  16. Scan scan = new Scan();
  17. scan.setFilter(list);
  18. scan.setFilter(new PageFilter(10));
  19. scanner = table.getScanner(scan);
  20.  
  21. scan.setMaxResultSize(10);
  22. scan.setMaxResultSize(10);
Add Comment
Please, Sign In to add comment