pyflink.table.WindowGroupedTable.select

WindowGroupedTable.select(*fields: pyflink.table.expression.Expression) → pyflink.table.table.Table

Performs a selection operation on a window grouped table. Similar to an SQL SELECT statement. The field expressions can contain complex expressions and aggregations.

Example:

>>> window_grouped_table.select(col('key'),
...                             col('window').start,
...                             col('value').avg.alias('valavg'))

Parameters

fields – Expression string.

Returns

The result table.