RE : Custom implementation of ISpoutWaitStrategy

[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
>