| | 11 | |
| | 12 | 在一个ROW里面根据字段名查询可以使用Column的各种Filter[[BR]] |
| | 13 | |
| | 14 | {{{ |
| | 15 | HTable t = ...; |
| | 16 | Scan s = ...; |
| | 17 | s.setStartRow("pets"); |
| | 18 | s.setStopRow("pets"); |
| | 19 | // get all columns for my pet "fluffy". |
| | 20 | Filter f = new ColumnRangeFilter(Bytes.toBytes("fluffy"), true, |
| | 21 | Bytes.toBytes("fluffz"), false); |
| | 22 | s.setFilter(f); |
| | 23 | s.setBatch(20); // avoid getting all columns for the HBase row |
| | 24 | ResultScanner rs = t.getScanner(s); |
| | 25 | for (Result r = rs.next(); r != null; r = rs.next()) { |
| | 26 | // r will now have all HBase columns that start with "fluffy", |
| | 27 | // which would represent a single row |
| | 28 | for (KeyValue kv : r.raw()) { |
| | 29 | // each kv represent - the latest version of - a column |
| | 30 | } |
| | 31 | } |
| | 32 | }}} |