Method putReadDeleteAtTimestamp

test/TestIntegration.java:197–223

Write two values to a HBase column and read them back, delete one, and read back the other.

()

   * delete one, and read back the other.
   */
  @Test
  public void putReadDeleteAtTimestamp() throws Exception {
    client.setFlushInterval(FAST_FLUSH);
    byte[] t = table.getBytes();
    byte[] k = "kprd@ts".getBytes();
    byte[] f = family.getBytes();
    // Make the qualifier unique to avoid running into HBASE-9879.
    byte[] q = ("q" + System.currentTimeMillis()
                + "-" + System.nanoTime()).getBytes();
    byte[] v1 = "val1".getBytes();
    byte[] v2 = "val2".getBytes();
    final PutRequest put1 = new PutRequest(t, k, f, q, v1, 100L);
    final PutRequest put2 = new PutRequest(t, k, f, q, v2, 200L);
    client.put(put1).join();
    client.put(put2).join();
    final GetRequest get = new GetRequest(t, k, f, q).maxVersions(2);
    final ArrayList<KeyValue> kvs = client.get(get).join();
    assertSizeIs(2, kvs);
    assertEq("val2", kvs.get(0).value());
    assertEq("val1", kvs.get(1).value());
    final DeleteRequest del = new DeleteRequest(t, k, f, q, 200L);
    del.setDeleteAtTimestampOnly(true);
    client.delete(del).join();
    final ArrayList<KeyValue> kvs2 = client.get(get).join();
    assertSizeIs(1, kvs2);
    assertEq("val1", kvs2.get(0).value());
  }

  /**
   * Call Append on a column for the first time and validate that it was