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
>
