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 >
signature.asc
Description: Message signed with OpenPGP using GPGMail
