You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@storm.apache.org by Denis DEBARBIEUX <dd...@norsys.fr> on 2015/12/22 12:03:53 UTC

Custom implementation of ISpoutWaitStrategy

Dear all,

I would to implement my own SpoutWaitStrategy. So I have to implement 
ISpoutWaitStrategy and then prepare and emptyEmit methods.

But, I do not understand the meaning of the parameter 'streak'. How 
should I use it?

Thanks for your help.

Denis

---
L'absence de virus dans ce courrier électronique a été vérifiée par le logiciel antivirus Avast.
https://www.avast.com/antivirus

RE : Custom implementation of ISpoutWaitStrategy

Posted by Denis DEBARBIEUX <dd...@norsys.fr>.

Thanks.

Denis



________________________________________
De : P. Taylor Goetz [ptgoetz@gmail.com]
Date d'envoi : mardi 22 décembre 2015 19:13
À : user@storm.apache.org
Objet : Re: Custom implementation of ISpoutWaitStrategy

If the call to a spout's `nextTuple()` method does not emit anything, Storm will call the `emptyEmit()` method with the number of times `nextTuple()` has consecutively failed to emit anything (`streak` will be reset to 0 if the spout emits something).


-Taylor

> On Dec 22, 2015, at 6:03 AM, Denis DEBARBIEUX <dd...@norsys.fr> wrote:
>
> Dear all,
>
> I would to implement my own SpoutWaitStrategy. So I have to implement
> ISpoutWaitStrategy and then prepare and emptyEmit methods.
>
> But, I do not understand the meaning of the parameter 'streak'. How
> should I use it?
>
> Thanks for your help.
>
> Denis
>
> ---
> L'absence de virus dans ce courrier électronique a été vérifiée par le logiciel antivirus Avast.
> https://www.avast.com/antivirus
>

Re: Custom implementation of ISpoutWaitStrategy

Posted by "P. Taylor Goetz" <pt...@gmail.com>.

If the call to a spout's `nextTuple()` method does not emit anything, Storm will call the `emptyEmit()` method with the number of times `nextTuple()` has consecutively failed to emit anything (`streak` will be reset to 0 if the spout emits something).

-Taylor

> On Dec 22, 2015, at 6:03 AM, Denis DEBARBIEUX <dd...@norsys.fr> wrote:
> 
> Dear all,
> 
> I would to implement my own SpoutWaitStrategy. So I have to implement
> ISpoutWaitStrategy and then prepare and emptyEmit methods.
> 
> But, I do not understand the meaning of the parameter 'streak'. How
> should I use it?
> 
> Thanks for your help.
> 
> Denis
> 
> ---
> L'absence de virus dans ce courrier électronique a été vérifiée par le logiciel antivirus Avast.
> https://www.avast.com/antivirus
>