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
>
