Perform operations on the data and then pass it to the next operator using push()
Uses RXJS streams where we represent Operators with subjects. Objects/Strings are passed to the next operator. Originally the project worked with Observables. But I could not get these to work with Multicast streams(needed for fragmenter).
Joins work by first collecting both streams till completion. And then passing these to the executeJoin function. The join operator itself will choose when to complete and push.
For now joins add the ptm_alias to all objects entering the join from the secondary input.
It would possibly be more efficient to only add this to the respective fields that are duplicate.