Obviously you cannot change what is in your jar file but if the bolt is already compiled you can try flux to change how your topology is linked. http://storm.apache.org/documentation/flux.html
On Wed, Nov 25, 2015 at 5:03 AM, Renya nath N <[email protected]> wrote: > Hi Ankur, > > Thank you for valuable reply, > Actually I was doing a project on intelligent query placemenet strategy for > real time analytics. Dynamic topology evolution is the main focus. Is it > possible to dynamically tune a topology when new queries( in terms of > bolts) submitted to the system? > > > Thank you > Renya Nath N > > On Wed, Nov 25, 2015 at 1:55 PM, Ankur Garg <[email protected]> wrote: > > > Hi Renya, > > > > Can you be more elaborate what exactly are u looking for . > > > > Specifically , what is a query here . Are these queries independent of > each > > other ? Where are u getting/retrieving these queries from . > > > > Nevertheless , assuming multiple queries means simple multiprocessing ,I > > think u r looking for parallelism hint while defining ur topologies like > > > > TopologyBuilder topicTopologyBuilder = new TopologyBuilder(); > > > > topicTopologyBuilder.setSpout("spoutName", new TopicListenerSpout(), > > 1); > > topicTopologyBuilder.setBolt("boltName", new TopicMysqlBolt(), 10 > > ).shuffleGrouping("spoutName"); > > > > Third parameter is what will allow multiple instances/threads of Spouts > and > > Bolts . > > > > > > > > On Wed, Nov 25, 2015 at 1:16 PM, Renya nath N <[email protected]> > wrote: > > > > > Sir, > > > > > > How can I process multile queries in aache storm? > > > Do I need to create separate topology for each query? > > > > > > > > > > > > > > > > > > > > > > > > Thank you > > > Renya Nath N > > > > > >
