Thanks Brian. I will try this one. Thank you! On Monday, June 29, 2015, Brian O'Neill <[email protected]> wrote:
> > You may want to use storm-cassandra-cql, especially if you are interacting > with the table data via CQL. > > Take a look at the examples, and let me know if you need additional help: > https://github.com/hmsonline/storm-cassandra-cql > > -brian > > --- > > *Brian O'Neill * > > Chief Technology Officer > > Health Market Science, a LexisNexis Company > > 215.588.6024 Mobile • @boneill42 <http://www.twitter.com/boneill42> > > > This information transmitted in this email message is for the intended > recipient only and may contain confidential and/or privileged material. If > you received this email in error and are not the intended recipient, or the > person responsible to deliver it to the intended recipient, please contact > the sender at the email above and delete this email and any attachments and > destroy any copies thereof. Any review, retransmission, dissemination, > copying or other use of, or taking any action in reliance upon, this > information by persons or entities other than the intended recipient is > strictly prohibited. > > > > > From: Ajay Chander <[email protected] > <javascript:_e(%7B%7D,'cvml','[email protected]');>> > Reply-To: <[email protected] > <javascript:_e(%7B%7D,'cvml','[email protected]');>> > Date: Monday, June 29, 2015 at 7:43 AM > To: "[email protected] > <javascript:_e(%7B%7D,'cvml','[email protected]');>" < > [email protected] > <javascript:_e(%7B%7D,'cvml','[email protected]');>> > Subject: Re: Storm_cassandra > > Any pointers on this? Thank you > > On Sunday, June 28, 2015, Ajay Chander <[email protected] > <javascript:_e(%7B%7D,'cvml','[email protected]');>> wrote: > >> Hi Everyone, >> >> I need some help with storm-Cassandra. We have a use case which has, let >> us say product_id and its quantity emitting from one storm bolt. >> >> Public void declareOutputFields(outputFieldsDeclarer declarer){ >> declarer.declare(new Fields("product_id", "quantity"));} >> >> Now I have created a table in Cassandra like >> >> Create table products(product_id varchar, quantity int, primary key >> (product_id)) with compact storage; >> >> Now when I produce some messages like product1, 5; >> Product2, 2; >> >> My Cassandra will have that data. And after some time if I produce >> (product1, 3) I want the data in my Cassandra to be updated dynamically >> such that it should have >> product1, 8 >> Product2, 2 >> >> How to make this happen? I am a newbie to these technology's. Any help is >> highly appreciated. >> >> Thank you, >> Ajay >> >
