pyflink.table.GroupedTable.select

GroupedTable.select(*fields: Union[str, pyflink.table.expression.Expression]) → pyflink.table.table.Table

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.