Hi Suneel,Depending on what exactly you want to to, please have a look at Flatten or CoGroupByKey:
https://beam.apache.org/documentation/programming-guide/#flatten https://beam.apache.org/documentation/programming-guide/#cogroupbykey Both are available in Python/Java. -Max On 18.03.19 23:37, Suneel Marthi wrote:
Could someone point me to how to do connected stream from 2 sources with both java and python api? Danke Sent from my iPhone
