You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Ajay Chander <aj...@gmail.com> on 2015/06/29 04:38:13 UTC
Storm_cassandra
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
Re: Storm_cassandra
Posted by Ajay Chander <aj...@gmail.com>.
Thanks Brian. I will try this one. Thank you!
On Monday, June 29, 2015, Brian O'Neill <bo...@alumni.brown.edu> 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 <ajay.chevva@gmail.com
> <javascript:_e(%7B%7D,'cvml','ajay.chevva@gmail.com');>>
> Reply-To: <user@storm.apache.org
> <javascript:_e(%7B%7D,'cvml','user@storm.apache.org');>>
> Date: Monday, June 29, 2015 at 7:43 AM
> To: "user@storm.apache.org
> <javascript:_e(%7B%7D,'cvml','user@storm.apache.org');>" <
> user@storm.apache.org
> <javascript:_e(%7B%7D,'cvml','user@storm.apache.org');>>
> Subject: Re: Storm_cassandra
>
> Any pointers on this? Thank you
>
> On Sunday, June 28, 2015, Ajay Chander <ajay.chevva@gmail.com
> <javascript:_e(%7B%7D,'cvml','ajay.chevva@gmail.com');>> 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
>>
>
Re: Storm_cassandra
Posted by Brian O'Neill <bo...@alumni.brown.edu>.
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 <aj...@gmail.com>
Reply-To: <us...@storm.apache.org>
Date: Monday, June 29, 2015 at 7:43 AM
To: "user@storm.apache.org" <us...@storm.apache.org>
Subject: Re: Storm_cassandra
Any pointers on this? Thank you
On Sunday, June 28, 2015, Ajay Chander <aj...@gmail.com> 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
Re: Storm_cassandra
Posted by Ajay Chander <aj...@gmail.com>.
Any pointers on this? Thank you
On Sunday, June 28, 2015, Ajay Chander <aj...@gmail.com> 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
>