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)

Reply via email to