This message was deleted.

In PyFlink does yield work as ctx.collect(element)?

@M C (Mac) It is almost same. Its just that ctx.collect has some additional benefits included in it but both emits single element only.