Method appendTwiceBatchedReturnRead

test/TestIntegration.java:295–317

()

  }

  @Test
  public void appendTwiceBatchedReturnRead() throws Exception {
    truncateTable(table);
    final double write_time = System.currentTimeMillis();
    final AppendRequest append = new AppendRequest(table, "a2", family, "q", "val");
    append.returnResult(true);
    final AppendRequest append2 = new AppendRequest(table, "a2", family, "q", "2ndv");
    append2.returnResult(true);
    final GetRequest get = new GetRequest(table, "a2", family, "q");
    final ArrayList<Deferred<Object>> deferreds = new ArrayList<Deferred<Object>>(2);
    deferreds.add(client.append(append));
    deferreds.add(client.append(append2));
    Deferred.group(deferreds).join();
    final ArrayList<KeyValue> kvs = client.get(get).join();
    assertSizeIs(1, kvs);
    final KeyValue kv = kvs.get(0);
    assertEq("a2", kv.key());
    assertEq(family, kv.family());
    assertEq("q", kv.qualifier());
    assertEq("val2ndv", kv.value());
    final double kvts = kv.timestamp();
    assertEquals(write_time, kvts, 5000.0);  // Within five seconds.
  }

  @Test
  public void basicScanMultipleRegions() throws Exception {