Method timestampsFilter

test/TestIntegration.java:1474–1499

Simple timestamps filter list tests.

()

  /** Simple timestamps filter list tests.  */
  @Test
  public void timestampsFilter() throws Exception {
    client.setFlushInterval(FAST_FLUSH);
    final byte[] tableBytes = Bytes.UTF8(table);
    final byte[] familyBytes = Bytes.UTF8(family);
    final byte[] qualifier = Bytes.UTF8("q");
    final PutRequest put1 =
      new PutRequest(tableBytes, Bytes.UTF8("tf1"), familyBytes, qualifier, Bytes.UTF8("v1"), 1L);
    final PutRequest put2 =
      new PutRequest(tableBytes, Bytes.UTF8("tf2"), familyBytes, qualifier, Bytes.UTF8("v2"), 2L);
    final PutRequest put3 =
      new PutRequest(tableBytes, Bytes.UTF8("tf3"), familyBytes, qualifier, Bytes.UTF8("v3"), 3L);
    Deferred.group(client.put(put1), client.put(put2), client.put(put3)).join();
    final Scanner scanner = client.newScanner(table);
    scanner.setFamily(family);
    scanner.setStartKey(Bytes.UTF8("tf"));
    scanner.setStopKey(Bytes.UTF8("tf4"));
    scanner.setFilter(new TimestampsFilter(1L, 3L));
    final ArrayList<ArrayList<KeyValue>> rows = scanner.nextRows().join();
    scanner.close().join();
    assertSizeIs(2, rows);
    assertSizeIs(1, rows.get(0));
    assertEq("v1", rows.get(0).get(0).value());
    assertSizeIs(1, rows.get(1));
    assertEq("v3", rows.get(1).get(0).value());
  }

  /** Simple first key only filter tests.  */
  @Test