Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- HTable hTable = new HTable(HBaseConnection.getConfiguration(),tablename);
- Scan s = new Scan();
- s.setBatch(batchSize);
- s.setCaching(cachingSize);
- s.setCacheBlocks(true);
- s.addFamily(ColumnFamily1);
- s.addFamily(ColumnFamily2);
- // at this point I need something like s.addFilter(FilterBiggerThan25k) or something like that
- ResultScanner scanner = hTable.getScanner(s);
- for (Result res = scanner.next(); res != null; res = scanner.next()) {
- // do something for rows where column amount > 25000
- ...
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement