Method compareFilters

test/TestIntegration.java:1281–1383

()

  }

  @Test
  public void compareFilters() throws Exception {
    client.setFlushInterval(FAST_FLUSH);
    final PutRequest put1 = new PutRequest(table, "cf1", family, "a", "v1");
    final PutRequest put2 = new PutRequest(table, "cf2", family, "b", "v2");
    final PutRequest put3 = new PutRequest(
        Bytes.UTF8(table),
        Bytes.UTF8("cf3"),
        Bytes.UTF8(family),
        Bytes.UTF8("c"),
        Bytes.UTF8("v3"),
        42);
    final PutRequest put4 = new PutRequest(
        Bytes.UTF8(table),
        Bytes.UTF8("cf3"),
        Bytes.UTF8(family),
        Bytes.UTF8("dep"),
        Bytes.UTF8("v4"),
        42);
    Deferred.group(
        Deferred.group(client.put(put1), client.put(put2)),
        Deferred.group(client.put(put3), client.put(put4))).join();

    final Scanner row_scanner = client.newScanner(table);
    row_scanner.setStartKey("cf1");
    row_scanner.setStopKey("cf4");
    row_scanner.setFilter(
        new RowFilter(CompareOp.NOT_EQUAL, new BinaryComparator(Bytes.UTF8("cf2"))));
    final ArrayList<ArrayList<KeyValue>> row_rows =
        row_scanner.nextRows().join();
    row_scanner.close().join();
    assertSizeIs(2, row_rows);
    assertSizeIs(1, row_rows.get(0));
    assertEq("v1", row_rows.get(0).get(0).value());
    assertSizeIs(2, row_rows.get(1));
    assertEq("v3", row_rows.get(1).get(0).value());
    assertEq("v4", row_rows.get(1).get(1).value());

    final Scanner family_scanner = client.newScanner(table);
    family_scanner.setFilter(
        new FamilyFilter(CompareOp.LESS_OR_EQUAL,
            new BinaryComparator(Bytes.UTF8("aSomeOtherFamily"))));
    final ArrayList<ArrayList<KeyValue>> family_rows =
        family_scanner.nextRows().join();
    family_scanner.close().join();
    assertNull(family_rows);

    final Scanner qualifier_scanner = client.newScanner(table);
    qualifier_scanner.setStartKey("cf1");
    qualifier_scanner.setStopKey("cf4");
    qualifier_scanner.setFilter(
        new QualifierFilter(CompareOp.GREATER,
            new BinaryComparator(Bytes.UTF8("b"))));
    final ArrayList<ArrayList<KeyValue>> qualifier_rows =
        qualifier_scanner.nextRows().join();
    qualifier_scanner.close().join();
    assertSizeIs(1, qualifier_rows);
    assertSizeIs(2, qualifier_rows.get(0));