Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- @Test
- public void testInsertCounter() {
- Mutator<String> m = createMutator(keyspace, se);
- MutationResult mr = m.insertCounter("k", "Counter1", createCounterColumn("name", 5));
- assertTrue("Execution time on single counter insert should be > 0", mr.getExecutionTimeMicro() > 0);
- assertTrue("Should have operated on a host", mr.getHostUsed() != null);
- CounterQuery<String, String> counter = new ThriftCounterColumnQuery<String,String>(keyspace, se, se);
- counter.setColumnFamily("Counter1").setKey("k").setName("name");
- assertEquals(new Long(5), counter.execute().get().getValue());
- }
Advertisement
Add Comment
Please, Sign In to add comment