Re: join two streams with pyflink

2024-04-02 Thread Biao Geng
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  于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": 1, "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  Student*
>
>
>
>


join two streams with pyflink

2024-04-02 Thread Fokou Toukam, Thierry
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": 
"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 Student