MCPcopy Create free account
hub / github.com/OpenTSDB/asynchbase / multiDelete

Method multiDelete

test/TestIntegration.java:467–487  ·  view source on GitHub ↗

Write a few KVs and delete them in one batch

()

Source from the content-addressed store, hash-verified

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

Callers

nothing calls this directly

Calls 5

assertSizeIsMethod · 0.95
setFlushIntervalMethod · 0.80
putMethod · 0.80
deleteMethod · 0.80
getMethod · 0.45

Tested by

no test coverage detected