Hi Flinker, how can you implement a theta join with the revised cross API? In particular, how can you _not_ emit for a given input pair?
With the old interface, not calling the collector was quite easy and obvious. Returning null in the new interface seems to be a bad idea. Or is there a different way to implement a theta join with the current Flink API? FlatMap with Broadcast? Best, Arvid
