Hi,
I have written a PartitionedSpout implementing the IPartitionedTridentSpout
interface.
The IBatchSpout interface has a method
void ack(long batchId);
which indicates completion of a transaction. What is the equivalent
methododology to receive Ack for transactions, when using
IPartitionedTridentSpout?
I need to build some logic to trigger an external system on completion of a
few transactions.
Thanks & Regards
MK

Reply via email to