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 <partha.mis...@man-es.com> 于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? > >
