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