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

Posted to user@storm.apache.org by Srinath C <sr...@gmail.com> on 2014/03/19 02:01:15 UTC

Tuple message id uniqueness

Hi,
    I was unable to figure out if the messageId of a tuple emitted from a
spout should be globally unique? Or does storm identify a tuple with a
combination of spout name, spout task Id and messageId?

Thanks,
Srinath.

Re: Tuple message id uniqueness

Posted by Srinath C <sr...@gmail.com>.

Thanks!


On Wed, Mar 19, 2014 at 10:46 AM, Nathan Marz <na...@nathanmarz.com> wrote:

> No, it doesn't have to be. You're in full control of it. Internally Storm
> generates its own tuple ID and maintains a map from that globally unique
> tuple id to your spout id. The spout id is simply used in the ack/fail
> methods of the spout (so that you know what was acked/failed)
>
>
> On Tue, Mar 18, 2014 at 6:01 PM, Srinath C <sr...@gmail.com> wrote:
>
>> Hi,
>>     I was unable to figure out if the messageId of a tuple emitted from a
>> spout should be globally unique? Or does storm identify a tuple with a
>> combination of spout name, spout task Id and messageId?
>>
>> Thanks,
>> Srinath.
>>
>>
>
>
> --
> Twitter: @nathanmarz
> http://nathanmarz.com
>

Re: Tuple message id uniqueness

Posted by Nathan Marz <na...@nathanmarz.com>.

No, it doesn't have to be. You're in full control of it. Internally Storm
generates its own tuple ID and maintains a map from that globally unique
tuple id to your spout id. The spout id is simply used in the ack/fail
methods of the spout (so that you know what was acked/failed)

On Tue, Mar 18, 2014 at 6:01 PM, Srinath C <sr...@gmail.com> wrote:

> Hi,
>     I was unable to figure out if the messageId of a tuple emitted from a
> spout should be globally unique? Or does storm identify a tuple with a
> combination of spout name, spout task Id and messageId?
>
> Thanks,
> Srinath.
>
>

-- 
Twitter: @nathanmarz
http://nathanmarz.com