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 wrote:
> Hi team, I have the use case is that I want to join two d
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 thisSELECT suppliers.supplier_id, suppliers.supplier_name, orders.order_dateFROM suppliers INNER JOIN ordersON suppliers.supplier_id = orders.supplier_id;Howe
