SimpleColumnPrefixFilter tests on a Get request.
()
| 1567 | |
| 1568 | /** SimpleColumnPrefixFilter tests on a Get request. */ |
| 1569 | @Test |
| 1570 | public void columnPrefixFilterOnGet() throws Exception { |
| 1571 | client.setFlushInterval(FAST_FLUSH); |
| 1572 | // Keep only rows with a column qualifier that starts with "qa". |
| 1573 | final PutRequest put1 = new PutRequest(table, "cpf1", family, "qa1", "v1"); |
| 1574 | final PutRequest put2 = new PutRequest(table, "cpf1", family, "qa2", "v2"); |
| 1575 | final PutRequest put3 = new PutRequest(table, "cpf1", family, "qa3", "v3"); |
| 1576 | final PutRequest put4 = new PutRequest(table, "cpf1", family, "qb4", "v4"); |
| 1577 | Deferred.group(Deferred.group(client.put(put1), client.put(put2)), |
| 1578 | Deferred.group(client.put(put3), client.put(put4))).join(); |
| 1579 | final GetRequest get = new GetRequest(table, "cpf1"); |
| 1580 | get.setFilter(new ColumnPrefixFilter("qa")); |
| 1581 | ArrayList<KeyValue> kvs = client.get(get).join(); |
| 1582 | assertSizeIs(3, kvs); |
| 1583 | assertEq("v1", kvs.get(0).value()); |
| 1584 | assertEq("v2", kvs.get(1).value()); |
| 1585 | assertEq("v3", kvs.get(2).value()); |
| 1586 | } |
| 1587 | |
| 1588 | /** Simple timestamps filter tests on a Get request. */ |
| 1589 | @Test |
nothing calls this directly
no test coverage detected