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?
>
>