pyflink.table.OverWindowedTable.select

OverWindowedTable.select(*fields: Expression) → Table

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

Example:

>>> over_windowed_table.select(col('c'),
...                            col('b').count.over(col('ow')),
...                            col('e').sum.over(col('ow')))

Parameters:

fields – Expression string.

Returns:

The result table.