Hi David,
Thanks for the confirmation. Let's fix the docs:
https://github.com/apache/flink/pull/23776
Thanks,
Alex
On Sun, 19 Nov 2023 at 01:55, David Anderson wrote:
> Hi, Alex!
>
> Yes, in PyFlink the various flatmap and process functions are implemented
> as generator functions, so they
Hi, Alex!
Yes, in PyFlink the various flatmap and process functions are implemented
as generator functions, so they use yield to emit results.
David
On Tue, Nov 7, 2023 at 1:16 PM Alexander Fedulov <
alexander.fedu...@gmail.com> wrote:
> Java ProcessFunction API defines a clear way to collect
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"
