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
