Method timestampsOnGet

test/TestIntegration.java:1589–1610

Simple timestamps filter tests on a Get request.

()

  /** Simple timestamps filter tests on a Get request.  */
  @Test
  public void timestampsOnGet() throws Exception {
    client.setFlushInterval(FAST_FLUSH);
    final byte[] tableBytes = Bytes.UTF8(table);
    final byte[] familyBytes = Bytes.UTF8(family);
    final byte[] rowBytes = Bytes.UTF8("row1");
    final PutRequest put1 = new PutRequest(tableBytes, rowBytes, familyBytes, Bytes.UTF8("q1"), Bytes.UTF8("v1"), 1L);
    final PutRequest put2 = new PutRequest(tableBytes, rowBytes, familyBytes, Bytes.UTF8("q2"), Bytes.UTF8("v2"), 2L);
    final PutRequest put3 = new PutRequest(tableBytes, rowBytes, familyBytes, Bytes.UTF8("q3"), Bytes.UTF8("v3"), 3L);
    final PutRequest put4 = new PutRequest(tableBytes, rowBytes, familyBytes, Bytes.UTF8("q4"), Bytes.UTF8("v4"), 4L);

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

    final GetRequest get = new GetRequest(table,  "row1");
    get.setMinTimestamp(2L);
    get.setMaxTimestamp(4L);
    ArrayList<KeyValue> kvs = client.get(get).join();
    assertSizeIs(2, kvs);
    assertEq("v2", kvs.get(0).value());
    assertEq("v3", kvs.get(1).value());
  }

  /** Basic reverse scan test. Modeled after the basic forward scan. */
  @Test