specifically use this method: http://nathanmarz.github.io/storm/doc/backtype/storm/topology/InputDeclarer.html#allGrouping(java.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, backtype.storm.tuple.Tuple, java.util.List) On Thu, Jan 15, 2015 at 9:26 AM, Nathan Leung <[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]> 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! >> >> >
