Hi Ian, You need to create two streams, and use https://nightlies.apache.org/flink/flink-docs-master/api/python/pyflink.datastream.html#pyflink.datastream.DataStream.connect to "join" them.
On Fri, 13 May 2022 at 14:06, lan tran <indigoblue7...@gmail.com> wrote: > Hi team, I have the use case is that I want to join two datastream that > have the same id. If we convert into sql we will have something like this > > SELECT suppliers.supplier_id, suppliers.supplier_name, orders.order_date > > FROM suppliers > > INNER JOIN orders > > ON suppliers.supplier_id = orders.supplier_id; > > However, I don’t see the function `joins` available in PyFlink, therefore, > if there is some guidance here, it would be help. Thanks team. > > Note: I know that using TableAPI would be easier. However, I just want to > know how it can be implemented using Datastream in PyFlink. > > Best, > Quynh > > > > Sent from Mail <https://go.microsoft.com/fwlink/?LinkId=550986> for > Windows > > >
