Method regression41

test/TestIntegration.java:2252–2272

Regression test for issue #41.

()

  /** Regression test for issue #41. */
  @Test
  public void regression41() throws Exception {
    client.setFlushInterval(SLOW_FLUSH);
    final byte[] table = TestIntegration.table.getBytes();
    final byte[] key = "cnt".getBytes();
    final byte[] family = TestIntegration.family.getBytes();
    final byte[] qual = { 'q' };
    final DeleteRequest del = new DeleteRequest(table, key, family, qual);
    del.setBufferable(false);
    client.delete(del).join();
    final int iterations = 100000;
    for (int i = 0; i < iterations; i++) {
      bufferIncrement(table, key, family, qual, 1);
    }
    client.flush().joinUninterruptibly();
    final GetRequest get = new GetRequest(table, key)
      .family(family).qualifier(qual);
    final ArrayList<KeyValue> kvs = client.get(get).join();
    assertSizeIs(1, kvs);
    assertEquals(iterations, Bytes.getLong(kvs.get(0).value()));
  }

  private static <T> void assertSizeIs(final int size,
                                       final Collection<T> list) {