Dear Community, I want to use Windowed Merge operator to merge two stream. To keep it simple, I'm currently looking to work with Global Window itself.
I have 2 stream both having datatypes as POJO and I want to join the two streams on one or more fields from the POJO (configurable). But I see the two input ports of KeyedWindowedMergeOperatorImpl are not compatible and cannot work with POJOs. Can you please provide me direction how can I use KeyedWindowedMergeOperatorImpl for this purpose? Thanks, Chinmay.
