pyflink.table.GroupedTable.select#
- GroupedTable.select(*fields: Expression) Table[source]#
Performs a selection operation on a grouped table. Similar to an SQL SELECT statement. The field expressions can contain complex expressions and aggregations.
Example:
>>> tab.group_by(col('key')).select(col('key'), col('value').avg.alias('average'))
- Parameters:
fields – Expression string that contains group keys and aggregate function calls.
- Returns:
The result table.