You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by hjh <ap...@163.com> on 2015/01/15 15:07:31 UTC
is it possible to send tuple to all bolts and spout without grouping
them
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!
Re: is it possible to send tuple to all bolts and spout without grouping
them
Posted by hjh <ap...@163.com>.
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 <ncleung@gmail.com
> <ma...@gmail.com>> 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 <applyhhj@163.com
> <ma...@163.com>> 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!
>
>
>
Re: is it possible to send tuple to all bolts and spout without
grouping them
Posted by Nathan Leung <nc...@gmail.com>.
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 <nc...@gmail.com> 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 <ap...@163.com> 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!
>>
>>
>
Re: is it possible to send tuple to all bolts and spout without
grouping them
Posted by Nathan Leung <nc...@gmail.com>.
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 <ap...@163.com> 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!
>
>