Yes, it should be emitting a POJO. This POJO can then be further used to join with a third POJO stream, thus behaving like a DB join.
It would be best if we can incorporate this into Schema Discovery design. Ajay On Wed, 15 Feb 2017 at 5:30 PM, Chinmay Kolhatkar <[email protected]> wrote: Dear Community, Currently PojoInnerJoin accumulation is accepting 2 POJOs but emitting a Map<String, Object>. I think it should be emitting POJO instead of Map<String, Object>. Please share your thoughts about this. Thanks, Chinmay.
