storm-cassandra integration

[varadha31590]

Hi,
I want to know the storm cassandra integration procedure. The program you have provided is difficult to understand for me. I need a simple cassandra bolt class which insert values into the cassandra database. if possible please suggest me, im a newbie to storm.

Thanks
Varadha

[boneill42]

This may be what you are looking for:
https://github.com/hmsonline/storm-cassandra/blob/master/src/main/java/com/hmsonline/storm/cassandra/bolt/CassandraBolt.java

[varadha31590]

Thanks boneill for your response...

I need the description of execution flow of the program which you sugessted , i surfed google through out the day to understand the storm-cassandra integration. if i found, it will be more helpful for understanding storm-cassandra concepts.

[boneill42]

Have you had a look at the example topologies:
https://github.com/hmsonline/storm-cassandra/tree/master/examples

Also, you may want to consider switching over to the storm-cassandra-cql implementation. That will have better long term support. This implementation uses Thrift, which is a legacy protocol for C*.