Hi Hitesh,
You are absolutely right. The PojoInnerJoin accumulation we have now is
only
to test the implementation of WindowedMergeOperator. I did not considered
the case you mentioned when developing, so please make changes to fix this.
Thanks,
Shunxin
On Wed, Feb 15, 2017 at 4:25 AM, Hitesh Kapoor <hit...@datatorrent.com>
wrote:
> Hi All,
>
> In PojoInnerJoin accumulation same field names are emitted as single field
> even if we don't take a join on them. For example consider the following 2
> POJO's on 2 streams
>
> POJO1
> {
> id: Int
> age : String
> }
>
> POJO2
> {
> id: Int
> age : String
> name : String
> }
>
> If we wish to take a join only on field id then the resulting stream
> contains the common named field(age) only from POJO2.
> So I am confused whether the resulting stream should contain the field
> 'age' from only POJO1 (or only POJO2) or it should contain the field 'age'
> from both the POJOs.
>
> I think it is a bug which should be fixed and the resulting stream should
> contain common named field from both the POJOs (and maybe rename it in the
> final output). Let me know your thoughts on it.
>
> Regards,
> Hitesh
>
