Thanks. Denis
________________________________________ De : P. Taylor Goetz [[email protected]] Date d'envoi : mardi 22 décembre 2015 19:13 À : [email protected] 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 <[email protected]> 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 >
