Method columnPaginationFilter

test/TestIntegration.java:1042–1107

Simple column pagination filter tests.

()

  /** Simple column pagination filter tests.  */
  @Test
  public void columnPaginationFilter() throws Exception {
    client.setFlushInterval(FAST_FLUSH);
    // Keep only rows with a column qualifier that starts with "qa".
    final PutRequest put1 = new PutRequest(table, "row1", family, "q1", "v1");
    final PutRequest put2 = new PutRequest(table, "row1", family, "q2", "v2");
    final PutRequest put3 = new PutRequest(table, "row1", family, "q3", "v3");
    final PutRequest put4 = new PutRequest(table, "row1", family, "q4", "v4");

    final PutRequest put5 = new PutRequest(table, "row2", family, "q1", "v5");
    final PutRequest put6 = new PutRequest(table, "row2", family, "q2", "v6");
    final PutRequest put7 = new PutRequest(table, "row2", family, "q3", "v7");

    Deferred.group(Deferred.group(client.put(put1), client.put(put2)),
        Deferred.group(client.put(put3), client.put(put4)),
        Deferred.group(client.put(put5), client.put(put6), client.put(put7))).join();

    // Test ColumnPaginationFilter(int limit, int offset)
    Scanner scanner = client.newScanner(table);
    scanner.setFamily(family);
    scanner.setStartKey("row1");
    scanner.setStopKey("row3");
    scanner.setFilter(new ColumnPaginationFilter(3, 1));
    ArrayList<ArrayList<KeyValue>> rows = scanner.nextRows().join();
    assertNotNull(rows);
    assertSizeIs(2, rows);
    ArrayList<KeyValue> kvs = rows.get(0);
    assertSizeIs(3, kvs);
    assertEq("v2", kvs.get(0).value());
    assertEq("v3", kvs.get(1).value());
    assertEq("v4", kvs.get(2).value());
    kvs = rows.get(1);
    assertSizeIs(2, kvs);
    assertEq("v6", kvs.get(0).value());
    assertEq("v7", kvs.get(1).value());

    // Test ColumnPaginationFilter(int limit, byte[] offset) - Only supported in HBase 0.96+
    scanner = client.newScanner(table);
    scanner.setFamily(family);
    scanner.setStartKey("row1");
    scanner.setStopKey("row3");
    scanner.setFilter(new ColumnPaginationFilter(3, Bytes.UTF8("q2")));

    try {
      rows = scanner.nextRows().join(); //Throws an UnsupportedOperationException if <= HBase 0.94

      // Test for running against >= HBase 0.96
      assertNotNull(rows);
      assertSizeIs(2, rows);
      kvs = rows.get(0);
      assertSizeIs(3, kvs);
      assertEq("v2", kvs.get(0).value());
      assertEq("v3", kvs.get(1).value());
      assertEq("v4", kvs.get(2).value());
      kvs = rows.get(1);
      assertSizeIs(2, kvs);
      assertEq("v6", kvs.get(0).value());
      assertEq("v7", kvs.get(1).value());