This is a bug if we consider a normal database join. All fields from both POJOs should be emitted in the result irrespective of the name.
Ajay On Wed, 15 Feb 2017 at 5:55 PM, Hitesh Kapoor <[email protected]> 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 >
