You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Software Dev <st...@gmail.com> on 2014/03/27 05:40:03 UTC
Auto acking
Sorry for the basic question but...
Where does BaseBasicBolt auto ack? It looks like it uses
BasicOutputCollector which doesn't even have an ack or fail method
whereas OutputCollector does?
Re: Auto acking
Posted by Angelo Genovese <an...@genovese.ca>.
Sorry, would have included this in the last email but I was on my phone.
The specific wrapper class I meant was
backtype.storm.topology.BasicBoltExecutor.
To see how the iBasicBolts get wrapped. have a look at
backtype.storm.topology.TopologyBuilder.setBolt(String id, IBasicBolt
bolt, Number parallelism_hint) (Line 170 in 0.9.1-incubating)
Ciao,
--
Angelo Genovese
On Thu, Mar 27, 2014 at 2:17 PM, Software Dev <st...@gmail.com> wrote:
> Ok, I havent come across that class.
>
> What creates that class?
>
> On Wed, Mar 26, 2014 at 10:21 PM, Angelo Genovese <an...@genovese.ca> wrote:
>> BasicBolts are wrapped automatically with a basic bolt executor. It does the
>> back/fail
>>
>> On Mar 26, 2014 9:40 PM, "Software Dev" <st...@gmail.com> wrote:
>>>
>>> Sorry for the basic question but...
>>>
>>> Where does BaseBasicBolt auto ack? It looks like it uses
>>> BasicOutputCollector which doesn't even have an ack or fail method
>>> whereas OutputCollector does?
Re: Auto acking
Posted by Software Dev <st...@gmail.com>.
Ok, I havent come across that class.
What creates that class?
On Wed, Mar 26, 2014 at 10:21 PM, Angelo Genovese <an...@genovese.ca> wrote:
> BasicBolts are wrapped automatically with a basic bolt executor. It does the
> back/fail
>
> On Mar 26, 2014 9:40 PM, "Software Dev" <st...@gmail.com> wrote:
>>
>> Sorry for the basic question but...
>>
>> Where does BaseBasicBolt auto ack? It looks like it uses
>> BasicOutputCollector which doesn't even have an ack or fail method
>> whereas OutputCollector does?
Re: Auto acking
Posted by Angelo Genovese <an...@genovese.ca>.
BasicBolts are wrapped automatically with a basic bolt executor. It does
the back/fail
On Mar 26, 2014 9:40 PM, "Software Dev" <st...@gmail.com> wrote:
> Sorry for the basic question but...
>
> Where does BaseBasicBolt auto ack? It looks like it uses
> BasicOutputCollector which doesn't even have an ack or fail method
> whereas OutputCollector does?
>