Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-20647

Use yield to generate output datas in ProcessFunction for Python DataStream

    XMLWordPrintableJSON

    Details

      Description

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                csq Shuiqiang Chen
                Reporter:
                csq Shuiqiang Chen
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: