Write a few KVs and delete them in one batch
()
| 465 | |
| 466 | /** Write a few KVs and delete them in one batch */ |
| 467 | @Test |
| 468 | public void multiDelete() throws Exception { |
| 469 | client.setFlushInterval(FAST_FLUSH); |
| 470 | final PutRequest put2 = new PutRequest(table, "mdk1", family, "q2", "val2"); |
| 471 | client.put(put2).join(); |
| 472 | final PutRequest put3 = new PutRequest(table, "mdk2", family, "q3", "val3"); |
| 473 | client.put(put3).join(); |
| 474 | final PutRequest put1 = new PutRequest(table, "mdk1", family, "q1", "val1"); |
| 475 | client.put(put1).join(); |
| 476 | final DeleteRequest del2 = new DeleteRequest(table, "mdk1", family, "q2"); |
| 477 | final DeleteRequest del3 = new DeleteRequest(table, "mdk2", family, "q3"); |
| 478 | final DeleteRequest del1 = new DeleteRequest(table, "mdk1", family, "q1"); |
| 479 | Deferred.group(client.delete(del2), client.delete(del3), |
| 480 | client.delete(del1)).join(); |
| 481 | GetRequest get = new GetRequest(table, "mdk1"); |
| 482 | ArrayList<KeyValue> kvs = client.get(get).join(); |
| 483 | assertSizeIs(0, kvs); |
| 484 | get = new GetRequest(table, "mdk2"); |
| 485 | kvs = client.get(get).join(); |
| 486 | assertSizeIs(0, kvs); |
| 487 | } |
| 488 | |
| 489 | /** Write a few KVs in different regions and delete them in one batch */ |
| 490 | @Test |
nothing calls this directly
no test coverage detected