Hi Pranav, Table Aggregate and Window Table Aggregate are now only supported in TableAPI, they are not supported by SQL yet. I think the most challenge is how to support those two features (Table Aggregate and Window Table Aggregate) based on standard SQL gramma since aggregate means return a single value based on a set of other values with same group key in ANSI SQL.
Best, JING ZHANG Pranav Patil <pranav.pa...@salesforce.com> 于2021年7月29日周四 上午1:27写道： > 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? >
