Hi,
I am relatively new to storm and wanted to ask a very trivial question, I
am facing issues while setting CassandraWriterBolt in my topology.
Code :
CassandraWriterBolt Historybolt = new
CassandraWriterBolt(async(simpleQuery(getEventHistoryQuery()).with(
all() )));
builder.setBolt("cassandra", Historybolt, 1)
.shuffleGrouping("cstar-query-stream");
Error :
Error:(43, 16) java: *no suitable method found for
setBolt(java.lang.String,org.apache.storm.cassandra.bolt.CassandraWriterBolt,int)*
method
backtype.storm.topology.TopologyBuilder.setBolt(java.lang.String,backtype.storm.topology.IRichBolt,java.lang.Number)
is not applicable
(argument mismatch;
org.apache.storm.cassandra.bolt.CassandraWriterBolt cannot be converted to
backtype.storm.topology.IRichBolt)
method
backtype.storm.topology.TopologyBuilder.setBolt(java.lang.String,backtype.storm.topology.IBasicBolt,java.lang.Number)
is not applicable
(argument mismatch;
org.apache.storm.cassandra.bolt.CassandraWriterBolt cannot be converted to
backtype.storm.topology.IBasicBolt)
DependencyVersion:
storm-core : 0.10.1
storm-cassandra : 1.0.1
Any help here would be appreciated
Thanks
--
Anirudh Chhangani
RiptideIO
