Thank you very much for the response, I will try that!!
On 01/15/2015 09:27 AM, Nathan Leung wrote:
specifically use this method:
http://nathanmarz.github.io/storm/doc/backtype/storm/topology/InputDeclarer.html#allGrouping(java.lang.String
<http://nathanmarz.github.io/storm/doc/backtype/storm/topology/InputDeclarer.html#allGrouping%28java.lang.String>,
java.lang.String)
and then when you emit, emit to the appropriate stream, e.g.
http://nathanmarz.github.io/storm/doc/backtype/storm/task/OutputCollector.html#emit(java.lang.String
<http://nathanmarz.github.io/storm/doc/backtype/storm/task/OutputCollector.html#emit%28java.lang.String>,
backtype.storm.tuple.Tuple, java.util.List)
On Thu, Jan 15, 2015 at 9:26 AM, Nathan Leung <[email protected]
<mailto:[email protected]>> wrote:
subscribe on your normal data channel using the appropriate
grouping (shuffle, fields, etc) on one stream, and subscribe to
the control stream using allGrouping.
On Thu, Jan 15, 2015 at 9:07 AM, hjh <[email protected]
<mailto:[email protected]>> wrote:
Hi everyone,
is it possible to send tuple(in program) to all bolts and
spout without grouping them, for example send a tuple to reset
all components in the topology but not using grouping
otherwise the topology will be too complicated. Thanks!