Hi everybody, I'm migrating my program from Flink to Beam SDK and stuck on joining two streams.
Flink has a dedicated operation "connect" and then you can apply CoFlatMap function to handle messages from different streams. Is there something similar in Beam? Thank you, Alex
