o that instance of operator ?
>
> Regards,
> Raja.
>
> From: Sandesh Hegde
> Reply-To: "users@apex.apache.org"
> Date: Thursday, July 7, 2016 at 4:29 PM
> To: "users@apex.apache.org"
> Subject: Re: hashing
>
> Where are you setting the StreamCod
received by each individual instance will be processed in the same order
> they arrived to that instance of operator ?
>
> Regards,
> Raja.
>
> From: Sandesh Hegde
> Reply-To: "users@apex.apache.org"
> Date: Thursday, July 7, 2016 at 4:29 PM
> To: "users@apex.
Thursday, July 7, 2016 at 4:29 PM
To: "users@apex.apache.org<mailto:users@apex.apache.org>"
mailto:users@apex.apache.org>>
Subject: Re: hashing
Where are you setting the StreamCodec?
Here is one method,
dag.setInputPortAttribute(campaignProcessor.input,
Context.PortCon
gt; Thanks.
>>
>> Regards,
>> Raja.
>>
>> From: "Raja.Aravapalli"
>> Date: Thursday, July 7, 2016 at 3:20 PM
>> To: "users@apex.apache.org"
>> Subject: hashing
>>
>>
>> Hi,
>>
>> I have an operator, which is
ate: Thursday, July 7, 2016 at 3:20 PM
> To: "users@apex.apache.org"
> Subject: hashing
>
>
> Hi,
>
> I have an operator, which is running in 3 instances I.e partions… And, I
> want all the records with same key, here my key is "String" type, to be
&
ja.aravapa...@target.com>>
Date: Thursday, July 7, 2016 at 3:20 PM
To: "users@apex.apache.org<mailto:users@apex.apache.org>"
mailto:users@apex.apache.org>>
Subject: hashing
Hi,
I have an operator, which is running in 3 instances I.e partions… And, I want
all the records with
Hi,
I have an operator, which is running in 3 instances I.e partions… And, I want
all the records with same key, here my key is "String" type, to be transferred
to same instance/partition.
But, I am unable to achieve this with my below codec.
import com.datatorrent.lib.codec.KryoSerializabl
