pyflink.table.OverWindowedTable.select

OverWindowedTable.select(*fields: pyflink.table.expression.Expression) → pyflink.table.table.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.