Re: checkAnd...

2013-05-15 Thread Lior Schachter
...@gmail.com To: user user@hbase.apache.org, Date: 04/27/2013 10:31 AM Subject:Re: checkAnd... found the checkAndIncrement Jira - HBASE-6712https://issues.apache.org/jira/browse/HBASE-6712 . Would be nice to have also checkandAppend. Any ideas how to solve to the use case I

RE: checkAnd...

2013-05-15 Thread Liu, Raymond
How about this one : https://issues.apache.org/jira/browse/HBASE-8542 Best Regards, Raymond Liu -Original Message- From: Lior Schachter [mailto:lior...@gmail.com] Sent: Thursday, May 16, 2013 1:18 AM To: user Subject: Re: checkAnd... yes, I believe this will cover most

Re: checkAnd...

2013-05-14 Thread Mike Spreitzer
Why not go whole hog and create checkAndMultiMutate (for all varieties of mutation) (all on the same row)? Thanks, Mike From: Lior Schachter lior...@gmail.com To: user user@hbase.apache.org, Date: 04/27/2013 10:31 AM Subject:Re: checkAnd... found the checkAndIncrement Jira

Re: checkAnd...

2013-04-30 Thread Lior Schachter
Hi, We have a simple HBase schema: row key = subscriber id. Column family A = counters - all kinds of aggregations. Events records have a UUID, in some scenarios we might get duplicate events. We should not count the duplicates. A possible solution was to keep event ids as qualifiers in another

Re: checkAnd...

2013-04-28 Thread Asaf Mesika
Yep. You can write a RegionObserver which take all event qualifiers with a time stamp larger than a certain grace period, sum it up, add it to the current value of the Count qualifier and emits an updated Count qualifier. I wrote something very similar for us at Akamai and it improved throughput

Re: checkAnd...

2013-04-27 Thread Ted Yu
Take a look at the following method in HRegionServer: public boolean checkAndPut(final byte[] regionName, final byte[] row, final byte[] family, final byte[] qualifier, final byte[] value, final Put put) throws IOException { You can create checkAndIncrement() in a similar way.

Re: checkAnd...

2013-04-27 Thread Lior Schachter
Hi Ted, Thanks for the prompt response. I've already had a look at HRegionServer.checkAndPut and the implementation looks quite straight forward. That's why I was wondering why the other 2 methods are not available...or planned (couldn't find Jira). Seems like a useful functionality. Anyhow, I'm

Re: checkAnd...

2013-04-27 Thread Jean-Marc Spaggiari
Hi Ted, Will it be a good idea to add it? Should we open a JIRA and implement checkANDIncrement? Might be pretty simple. JM 2013/4/27 Ted Yu yuzhih...@gmail.com: Take a look at the following method in HRegionServer: public boolean checkAndPut(final byte[] regionName, final byte[] row,

Re: checkAnd...

2013-04-27 Thread Lior Schachter
found the checkAndIncrement Jira - HBASE-6712https://issues.apache.org/jira/browse/HBASE-6712 . Would be nice to have also checkandAppend. Any ideas how to solve to the use case I described ? On Sat, Apr 27, 2013 at 4:46 PM, Jean-Marc Spaggiari jean-m...@spaggiari.org wrote: Hi Ted, Will

Re: checkAnd...

2013-04-27 Thread Ted Yu
It would be nice to know a bit more about your schema. How many tables do you use in the scenario you described ? One for user (counter), one for event ? Or just one table for all related information ? bq. to have an event_id qualifier for each incoming event Would you store the event_id