Hi Thierry,
Your case is not very complex and I believe all programming language(e.g.
Java, Python, SQL) interfaces of flink can do that.
When using pyflink, you can use pyflink datastream/table/SQL API.
Here are some examples of using pyflink table api:
Hi,
i have 2 streams as sean in this example (6> {"tripId": "275118740",
"timestamp": "2024-04-02T06:20:00Z", "stopSequence": 13, "stopId": "61261",
"bearing": 0.0, "speed": 0.0, "vehicleId": "39006", "routeId": "747"}
1> {"visibility": 1, "weather_conditions": "clear sky", "timestamp":
