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]> Reply-To: <[email protected]> Date: Monday, June 29, 2015 at 7:43 AM To: "[email protected]" <[email protected]> Subject: Re: Storm_cassandra Any pointers on this? Thank you On Sunday, June 28, 2015, Ajay Chander <[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
