Shuiqiang Chen created FLINK-20647: -------------------------------------- Summary: Use yield to generate output datas in ProcessFunction for Python DataStream Key: FLINK-20647 URL: https://issues.apache.org/jira/browse/FLINK-20647 Project: Flink Issue Type: Improvement Components: API / Python Reporter: Shuiqiang Chen Fix For: 1.13.0
Currently, users need to use a `collector` to collect the output of their ProcessFunction. We should use yield to make it more efficient that avoid using an array buffer to store the collected data, and it would be more pythonic as well. -- This message was sent by Atlassian Jira (v8.3.4#803005)