Re: Cassandra Mutation object decoding

2016-11-23 Thread Sanal Vasudevan
Hi Nate, Thank you. I can give it a try. Any examples you can point me to using QueryProcessor to read operations from the CommitLogs? Best regards, Sanal On Thu, Nov 24, 2016 at 1:22 PM, Nate McCall wrote: > > I must say that it is really encouraging to get your

Re: Cassandra Mutation object decoding

2016-11-23 Thread Nate McCall
> I must say that it is really encouraging to get your thoughts. > Thanks a ton Benjamin, Jacques-Henri, Jordan Nate and Chris. > > I do not have access on the client side where the CQL is executed. QueryHandler (I called it QueryProcessor incorrectly in my initial reply) is server side:

Re: Cassandra Mutation object decoding

2016-11-23 Thread Sanal Vasudevan
I must say that it is really encouraging to get your thoughts. Thanks a ton Benjamin, Jacques-Henri, Jordan Nate and Chris. I do not have access on the client side where the CQL is executed. One of my requirements is that my app should not to affect the performance of the cassandra cluster or

Re: Cassandra Mutation object decoding

2016-11-23 Thread Benjamin Lerer
> > My goal is to reconstruct the CQL operation from the Mutation object. > So that I can trigger the same action on another NoSQL target like MongoDB. > There are different way of keeping your 2 database in sync. Unfortunatly, they all have some trade offs (as always ;-)) 1. If you have

RE: Cassandra Mutation object decoding

2016-11-23 Thread Jacques-Henri Berthemet
- From: J. D. Jordan [mailto:jeremiah.jor...@gmail.com] Sent: mercredi 23 novembre 2016 07:13 To: dev@cassandra.apache.org Subject: Re: Cassandra Mutation object decoding You may also want to look at the triggers interface. > On Nov 22, 2016, at 7:45 PM, Chris Lohfink <chris.lohf...@datast

Re: Cassandra Mutation object decoding

2016-11-22 Thread J. D. Jordan
You may also want to look at the triggers interface. > On Nov 22, 2016, at 7:45 PM, Chris Lohfink wrote: > > There are different kinds of tombstones, a partition tombstone is held in > the MutableDeletionInfo of the PartitionUpdate that you can get from >

Re: Cassandra Mutation object decoding

2016-11-22 Thread Nate McCall
Have you explored the QueryProcessor interface? That is a legitimate extension point and may be a more suitable layer at which to integrate. On Wed, Nov 23, 2016 at 1:59 PM, Sanal Vasudevan wrote: > Hi Bejamin, > > Nice to hear from you. > > My goal is to reconstruct the CQL

Re: Cassandra Mutation object decoding

2016-11-22 Thread Chris Lohfink
There are different kinds of tombstones, a partition tombstone is held in the MutableDeletionInfo of the PartitionUpdate that you can get from deletionInfo() method which returns the private deletionInfo field from the holder. There are also row and cell deletions so you have to handle each of

Re: Cassandra Mutation object decoding

2016-11-22 Thread Sanal Vasudevan
Hi Bejamin, Nice to hear from you. My goal is to reconstruct the CQL operation from the Mutation object. So that I can trigger the same action on another NoSQL target like MongoDB. Please let me know know if you have ideas? Many thanks. Sanal On Tue, Nov 22, 2016 at 7:28 PM, Benjamin Lerer

Re: Cassandra Mutation object decoding

2016-11-22 Thread Benjamin Lerer
Hi Sanal, What you want to do is not an easy stuff and it might break with new major releases. My question would be: why do you want to do that? There might be another way to reach the same goal. Benjamin On Mon, Nov 21, 2016 at 7:14 PM, Sanal Vasudevan wrote: > Thank

Re: Cassandra Mutation object decoding

2016-11-21 Thread Sanal Vasudevan
Thank you Vladimir. Anyone else has any other ideas as to how this can be done? Many thanks, Sanal On Sun, Nov 20, 2016 at 4:46 AM, Vladimir Yudovin wrote: > Hi Sanal, > > > > do we have metadata inside Mutation object to decode whether the CQL > was an INSERT or UPDATE

Re: Cassandra Mutation object decoding

2016-11-19 Thread Vladimir Yudovin
Hi Sanal, do we have metadata inside Mutation object to decode whether the CQL was an INSERT or UPDATE operation? I'm not sure it's possible to distinguish them - both of them just add data to SSTable. Best regards, Vladimir Yudovin, Winguzone - Hosted Cloud Cassandra Launch your