apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Shunxin Lu <lushun...@gmail.com>
Subject Re: APEXMALHAR-2400 In PojoInnerJoin accumulation same field names are emitted as single field
Date Wed, 15 Feb 2017 18:57:22 GMT
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 <hitesh@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
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message