PyFlink DataStream API

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

PyFlink DataStream API

Partha Mishra
Hi,

Can anyone suggest if PyFlink Data Stream APIs (available from Flink 1.12) are being properly tested and used in any production environment/use-case without any issue and gives expected performance?

Reply | Threaded
Open this post in threaded view
|

Re: PyFlink DataStream API

Shuiqiang Chen
Hi Partha,

PyFlink DataStream API is a newly introduced feature in Flink 1.12.
Currently, some basic operations (map/flat_map/filter/key_by/process, etc),
timer and state access operations are supported. We are also continuously
improving and enriching these APIs. Looking forward to your feedback!

Best,
Shuiqiang

Partha Mishra <[hidden email]> 于2021年2月3日周三 下午8:08写道:

> Hi,
>
> Can anyone suggest if PyFlink Data Stream APIs (available from Flink 1.12)
> are being properly tested and used in any production environment/use-case
> without any issue and gives expected performance?
>
>