How to identify Transaction success in IPartitionedTridentSpout?

[Karthikeyan Muthukumarasamy <mk...@gmail.com>]

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

Re: How to identify Transaction success in IPartitionedTridentSpout?

[Karthikeyan Muthukumarasamy <mk...@gmail.com>]

Hi,
Can someone please attempt to answer this question? Its a crucial need for
my project.
Without a deterministic way to find out when a transaction is completed, I
cant trigger the related actions happening outside of the trident topology.
If you feel more details are required on the question, please let me know.
Thanks in advance!
MK



On Fri, Feb 14, 2014 at 9:34 PM, Karthikeyan Muthukumarasamy <
mkarthikswamy@gmail.com> wrote:

> 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
>
>