Hi, As far as I can tell the answer is unfortunately no. With Table API (SQL) things are much simpler, as you have a restricted number of types of columns that you need to support and you don't need to support arbitrary Java classes as the records.
I'm shooting blindly here, but maybe you can use your Python UDF in Table API and then convert a Table to DataStream? [1] Piotrek [1] https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/data_stream_api/ śr., 16 lut 2022 o 09:46 Jesry Pandawa <jesry.p.pand...@gmail.com> napisał(a): > 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 >
