Hello, Currently, Flink already supports adding Python UDF and using that on Flink Java job. It can be used on Table API. Can we do the same for creating custom python function for Datastream transformation and use that on Flink Java job?
Regards, Jesry
