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 <get2sa...@gmail.com> wrote:
> 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 <benjamin.le...@datastax.com
>> wrote:
>
>> 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 <get2sa...@gmail.com>
>> wrote:
>>
>> > 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 <vla...@winguzone.com>
>> > wrote:
>> >
>> > > 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 cluster in minutes.
>> > >
>> > >
>> > >
>> > >
>> > >
>> > > ---- On Fri, 18 Nov 2016 15:55:00 -0500Sanal Vasudevan &
>> > > lt;get2sa...@gmail.com> wrote ----
>> > >
>> > >
>> > >
>> > >
>> > > Hi there,
>> > >
>> > >
>> > >
>> > > I am trying to read the Commit logs to decode the original CQL which
>> > used.
>> > >
>> > > I get to the point an implemention of CommitLogReadHandler is able to
>> > push
>> > >
>> > > back Mutation objects from the Commit logs.
>> > >
>> > >
>> > >
>> > > Questions:
>> > >
>> > > 1) CQL: delete from myks.mytable where key1 = 1;
>> > >
>> > > For the above CQL, the Mutation object has zero objects of
>> > >
>> > > org.apache.cassandra.db.rows.Row inside ParitionUpdate object.
>> > >
>> > > Is this the only way to detect a DELETE operation? or we have any other
>> > >
>> > > metadata to indicate a DELETE operation?
>> > >
>> > > mutation.getPartitionUpdates().forEach(rows -> {
>> if(rows.isEmpty())
>> > >
>> > > System.out.println("May be a DELETE operation") });
>> > >
>> > > 2) Likewise do we have metadata inside Mutation object to decode
>> whether
>> > >
>> > > the CQL was an INSERT or UPDATE operation?
>> > >
>> > >
>> > >
>> > > Josh Mckenzie indicated that PartitionUpdate.deletionInfo
>> > >
>> > > (MutableDeletionInfo) may have some information but deletionInfo is
>> > > private.
>> > >
>> > >
>> > >
>> > > Basically, I am looking for help to find a way to classify Mutation
>> > object
>> > >
>> > > to INSERT/UPDATE/DELETE with related column and key information.
>> > >
>> > >
>> > >
>> > > Many thanks.
>> > >
>> > > --
>> > >
>> > > Sanal
>> > >
>> > >
>> > >
>> > >
>> > >
>> > >
>> > >
>> >
>> >
>> > --
>> > Sanal Vasudevan Nair
>> >
>>
>
>
>
> --
> Sanal Vasudevan Nair
