Cassandra bolt

2014-09-25 Thread Strulovitch, Zack
I've updated to 0.9.2 from pre-apache version 0.9.0.1 (which broke my Cassandra bolt implemented using this code : https://github.com/tjake/stormscraperhttps://github.com/tjake/stormscraper ) According to some posts, this is due to netty conflict. Could anyone please suggest me an alternative

Re: Cassandra bolt

2014-09-25 Thread Harsha
did you tried [1]https://github.com/ptgoetz/storm-cassandra. On Thu, Sep 25, 2014, at 11:20 AM, Strulovitch, Zack wrote: I've updated to 0.9.2 from pre-apache version 0.9.0.1 (which broke my Cassandra bolt implemented using this code : [2]https://github.com/tjake/stormscraper[3]https

Re: Cassandra bolt

2014-09-25 Thread Robert Lee
to 0.9.2 from pre-apache version 0.9.0.1 (which broke my Cassandra bolt implemented using this code : https://github.com/tjake/stormscraperhttps://github.com/tjake/stormscraper ) According to some posts, this is due to netty conflict. Could anyone please suggest me an alternative reliable

RE: Cassandra bolt

2014-09-25 Thread Strulovitch, Zack
Thank you very much Dan From: Dan DeCapria, CivicScience [dan.decap...@civicscience.com] Sent: Thursday, September 25, 2014 3:08 PM To: user@storm.incubator.apache.org Subject: Re: Cassandra bolt This might be useful to you as well: Netty Issue (I'm using Storm-Kafka and Kafka as well): rm

cassandra bolt config uses illegal character in config; makes storm throw exception

2014-01-13 Thread Adrian Mocanu
Hi all, I'm trying to learn how to use CassandraCounterBatchingBolt from storm-contrib project on github. When I run my topology in LOCAL CLUSTER MODE, it throws: InvalidTopologyException(msg:Topology name cannot contain any of the following: #{. / : \\}) And I think it's because the Cassandra

Re: Cassandra bolt

2014-01-10 Thread Vladi Feigin
*From:* Vladi Feigin [mailto:vladi...@gmail.com] *Sent:* January-04-14 2:00 AM *To:* user@storm.incubator.apache.org *Subject:* Re: Cassandra bolt Hi Adrian, Why you don't use C* counters? Looks like your scenario fits for this. I think CassandraCounterBatchingBolt provides what you

RE: Cassandra bolt

2014-01-06 Thread Adrian Mocanu
Subject: Re: Cassandra bolt Hi Adrian, Why you don't use C* counters? Looks like your scenario fits for this. I think CassandraCounterBatchingBolt provides what you need Vladi On Fri, Jan 3, 2014 at 11:00 PM, Adrian Mocanu amoc...@verticalscope.commailto:amoc...@verticalscope.com wrote: Happy

RE: Cassandra bolt

2014-01-06 Thread Adrian Mocanu
@storm.incubator.apache.org Subject: RE: Cassandra bolt Hi I am actually looking into using CassandraCounterBatchingBolt but atm I'm not sure how Cassandra handles these eventual consistency issues so I need to research that. The reason I mention this issues is because I cannot find anywhere in the code where before

Cassandra bolt

2014-01-03 Thread Adrian Mocanu
Happy New Year all! I'm working on a solution for the following scenario: I have tuples coming to a cassandra bolt. The tuples are of this form: TupleData(String name, Int count, Long time) Time field is unique per batch only but not overall because some tuples may come in late but have

Re: Cassandra bolt

2014-01-03 Thread Brian O'Neill
@storm.incubator.apache.org user@storm.incubator.apache.org Subject: Cassandra bolt Happy New Year all! I'm working on a solution for the following scenario: I have tuples coming to a cassandra bolt. The tuples are of this form: TupleData(String name, Int count, Long time) Time field is unique per batch only

RE: Cassandra bolt

2014-01-03 Thread Michael Oczkowski
: Cassandra bolt Adrian, See the email I just sent out to Laurent. We have the exact same use case, and we are evaluating the use of lightweight transactions (available in C* 2.0) to accomplish what you described without falling into all the traps involved in a read-before-write counter update. I

Re: Cassandra bolt

2014-01-03 Thread Brian O'Neill
@storm.incubator.apache.org Subject: RE: Cassandra bolt Brian, If you¹re considering using transactions you may want to read this. http://aphyr.com/posts/294-call-me-maybe-cassandra/ From: Brian O'Neill [mailto:boneil...@gmail.com] On Behalf Of Brian O'Neill Sent: Friday, January 3, 2014 2:10 PM To: user

RE: Cassandra bolt

2014-01-03 Thread Adrian Mocanu
Hi Brian Thanks for the reply. Currently using raw storm; doing ok without trident. For me the use case is a simpler because I use fieldGrouping so all tuples w the same ID will go to the same Cassandra bolt which means no other bolts will update the values for the tuples read by current bolt

Re: Cassandra bolt

2014-01-03 Thread Vladi Feigin
for the following scenario: I have tuples coming to a cassandra bolt. The tuples are of this form: TupleData(String name, Int count, Long time) Time field is unique per batch only but not overall because some tuples may come in late but have the same name and time but different count. For example: I can