You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Dian Fu (Jira)" <ji...@apache.org> on 2020/12/17 09:49:00 UTC

[jira] [Assigned] (FLINK-20647) Use yield to generate output datas in ProcessFunction for Python DataStream

     [ https://issues.apache.org/jira/browse/FLINK-20647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dian Fu reassigned FLINK-20647:
-------------------------------

    Assignee: Shuiqiang Chen

> 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
>    Affects Versions: 1.12.0
>            Reporter: Shuiqiang Chen
>            Assignee: Shuiqiang Chen
>            Priority: Major
>             Fix For: 1.13.0, 1.12.1
>
>
> 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)