Join two data stream using DataStream API using PyFlink

[lan tran]

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 for Windows