Hi Alexander, In Beam you probably want CoGroupByKey [1]. You might also check out the Join Library [2].
Kenn [1] https://beam.apache.org/documentation/programming-guide/#cogroupbykey [2] https://beam.apache.org/documentation/sdks/java-extensions/#join-library On Mon, Oct 15, 2018 at 11:50 AM Alexander Smirnov < [email protected]> wrote: > 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 >
