Dear all, I've noticed that there are some missing functionnalities in the Pyflink API that i would be willing to implement. To name a few:
* Table API: WindowGroupedTable does not implement the flat_aggregate method * Datastream API: No support for WindowJoin and JoinFunction (I saw there is an umbrella JIRA ticket for improving pyflink Datastream Window<https://issues.apache.org/jira/browse/FLINK-26477> support but unfortunately there is no mention of WindowJoins) * Execution environment: No support for adding custom Job Listeners I would be willing to propose a base implementation for each of the following points above and submit a PR, provided that someone with a bit more experience than me on the flink project is willing to point me in the right direction ! Feel free to let me know if you would be interested ! Best regards, Hugo Polsinelli
