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: https://nightlies.apache.org/flink/flink-docs-master/api/python/examples/table/basic_operations.html https://github.com/apache/flink/blob/master/flink-python/pyflink/table/tests/test_join.py
Hope it helps! Best, Biao Geng Fokou Toukam, Thierry <thierry.fokou-touka...@ens.etsmtl.ca> 于2024年4月2日周二 15:41写道: > 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": 10000, "weather_conditions": "clear sky", "timestamp": > "2024-04-02T02:19:39.281768"}*) and i want to merge them based on > timestamp value. Which flink can i use or how can i do it? > > Thanks! > > *Thierry FOKOU *| * IT M.A.Sc <http://M.A.Sc> Student* > > > >