Simple ColumnPaginationFilter filter test on a Get request.
()
| 1544 | |
| 1545 | /** Simple ColumnPaginationFilter filter test on a Get request. */ |
| 1546 | @Test |
| 1547 | public void columnPaginationFilterOnGet() throws Exception { |
| 1548 | client.setFlushInterval(FAST_FLUSH); |
| 1549 | final PutRequest put1 = new PutRequest(table, "row1", family, "q1", "v1"); |
| 1550 | final PutRequest put2 = new PutRequest(table, "row1", family, "q2", "v2"); |
| 1551 | final PutRequest put3 = new PutRequest(table, "row1", family, "q3", "v3"); |
| 1552 | final PutRequest put4 = new PutRequest(table, "row1", family, "q4", "v4"); |
| 1553 | |
| 1554 | Deferred.group(Deferred.group(client.put(put1), client.put(put2)), |
| 1555 | Deferred.group(client.put(put3), client.put(put4))).join(); |
| 1556 | |
| 1557 | // Test ColumnPaginationFilter(int limit, int offset) |
| 1558 | final GetRequest get = new GetRequest(table, "row1"); |
| 1559 | get.setFilter(new ColumnPaginationFilter(3, 1)); |
| 1560 | ArrayList<KeyValue> kvs = client.get(get).join(); |
| 1561 | assertNotNull(kvs); |
| 1562 | assertSizeIs(3, kvs); |
| 1563 | assertEq("v2", kvs.get(0).value()); |
| 1564 | assertEq("v3", kvs.get(1).value()); |
| 1565 | assertEq("v4", kvs.get(2).value()); |
| 1566 | } |
| 1567 | |
| 1568 | /** SimpleColumnPrefixFilter tests on a Get request. */ |
| 1569 | @Test |
nothing calls this directly
no test coverage detected