Java ProcessFunction API defines a clear way to collect data via the Collector object.
PyFlink documentation also refers to the Collector [1] , but it is not being passed to the function and is also nowhere to be found in the pyflink source code. How can multiple elements be collected? Is "yield" the designated way to achieve this? [1] https://nightlies.apache.org/flink/flink-docs-master/api/python/pyflink.datastream.html#pyflink.datastream.CoProcessFunction.process_element1 Best, Alex
