I want to create a Python UDF for a table aggregate function. The documentation explains this, and how to use its results by calling the flatAggregate function. However, I would not like to use the Table API. I would like to call the table aggregate function from Flink SQL. I'm using Flink 1.13. My function returns the Row type.
I'm not able to use LATERAL TABLE to expand as with a normal table function: SELECT T.value FROM table, LATERAL TABLE (tableAggr(table.data)) as T I'm also not able to say, for example SELECT T.value FROM table, tableAggr(table.data) as T Do I need to write a DataTypeHint? Or how do I expand the table into its rows and access them?
