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

Posted to user@storm.apache.org by Myidealand account <my...@gmail.com> on 2014/01/16 11:48:19 UTC

Transactional spout Implementation

Hello,

My uderstanding is Masterbatch spout coordinator calls isready() on
coordinator then initializetransaction , then  emitBatch of emitter then
success of  emitter , then success of  coordinator .
Is there any way through which I can set a flag in emitter success method
to stop calling Masterbatch spout coordinator  isready() that means my
purpose is next batch should be called only when  emitter success
method callNextBatch
flag is true which based on some logic I want to set programmatically.