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

Posted to dev@storm.apache.org by ABHIJIT SINGH <ku...@gmail.com> on 2014/11/19 22:15:45 UTC

REQ: Need help regarding spout initialization

Hi,
This is Abhijit from Bangalore, India. I am currently facing a problem
while initializing a spout that implements 'IPartitionedTransactionSpout'.
There is no method like open() where in I can initialize my spout. Could
you please share any workaround for this.

PS : There are certain objects that are not serializable hence I am not
sending them as a part of the constructor. of the spout




Thanks & Regards,
Abhijit
+91 9986032638

Re: REQ: Need help regarding spout initialization

Posted by Bobby Evans <ev...@yahoo-inc.com.INVALID>.

I don't see anything that does it directly as a part of the IPartitionedTransactionSpout, but the Emitter has cleanupBefore and the Coordinator has initializeTransaction that could be used simmilarly.  Transactional topologies have been deprecated in storm in favor of trident.  You may want to look at trident as an alternative too.
 - Bobby
 

     On Wednesday, November 19, 2014 3:21 PM, ABHIJIT SINGH <ku...@gmail.com> wrote:
   

 Hi,
This is Abhijit from Bangalore, India. I am currently facing a problem
while initializing a spout that implements 'IPartitionedTransactionSpout'.
There is no method like open() where in I can initialize my spout. Could
you please share any workaround for this.

PS : There are certain objects that are not serializable hence I am not
sending them as a part of the constructor. of the spout




Thanks & Regards,
Abhijit
+91 9986032638