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?
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
Dian Fu created FLINK-22070:
---
Summary: Support FileSink in PyFlink DataStream API
Key: FLINK-22070
URL: https://issues.apache.org/jira/browse/FLINK-22070
Project: Flink
Issue Type: Sub-task
zhangjingcun created FLINK-26444:
Summary: Window allocator supporting pyflink datastream API
Key: FLINK-26444
URL: https://issues.apache.org/jira/browse/FLINK-26444
Project: Flink
Issue
Juntao Hu created FLINK-27414:
-
Summary: Support operator state in PyFlink DataStream API
Key: FLINK-27414
URL: https://issues.apache.org/jira/browse/FLINK-27414
Project: Flink
Issue Type: New
Dian Fu created FLINK-27584:
---
Summary: Support broadcast state in PyFlink DataStream API
Key: FLINK-27584
URL: https://issues.apache.org/jira/browse/FLINK-27584
Project: Flink
Issue Type: New
Dian Fu created FLINK-21994:
---
Summary: Support FLIP-27 based FileSource connector in PyFlink
DataStream API
Key: FLINK-21994
URL: https://issues.apache.org/jira/browse/FLINK-21994
Project: Flink
Dian Fu created FLINK-22058:
---
Summary: Support FLIP-27 based NumberSequenceSource connector in
PyFlink DataStream API
Key: FLINK-22058
URL: https://issues.apache.org/jira/browse/FLINK-22058
Project: Flink
Dian Fu created FLINK-21971:
---
Summary: Support FLIP-27 based kafka source connector in PyFlink
DataStream API
Key: FLINK-21971
URL: https://issues.apache.org/jira/browse/FLINK-21971
Project: Flink
