Thanks, CoGroupByKey is what i need. On Tue, Mar 19, 2019 at 12:24 PM Maximilian Michels <[email protected]> wrote:
> 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 > > >
