Skip to content

Instantly share code, notes, and snippets.

@shrijeet
Created September 20, 2012 23:50
Show Gist options
  • Save shrijeet/3759005 to your computer and use it in GitHub Desktop.
Save shrijeet/3759005 to your computer and use it in GitHub Desktop.
[bug report] Client shutdown (without explicit flush) does not flush buffered atomic increments
import org.hbase.async.AtomicIncrementRequest;
import org.hbase.async.HBaseClient;
public class HBaseIncExample {
public static void main(String [] args) throws Exception {
HBaseClient client = new HBaseClient("rasalghul");
AtomicIncrementRequest req = new AtomicIncrementRequest("t0", "k1", "f1", "q1");
for (int i = 0; i < 100; i++) {
client.bufferAtomicIncrement(req);
}
client.shutdown().join();
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment