pyflink.table.Table.add_or_replace_columns

Table.add_or_replace_columns(*fields: Expression) → Table

Adds additional columns. Similar to a SQL SELECT statement. The field expressions can contain complex expressions, but can not contain aggregations. Existing fields will be replaced if add columns name is the same as the existing column name. Moreover, if the added fields have duplicate field name, then the last one is used.

Example:

>>> from pyflink.table.expressions import col, concat
>>> tab.add_or_replace_columns((col('a') + 1).alias('a1'),
...                            concat(col('b'), 'sunny').alias('b1'))

Parameters:

fields – Column list string.

Returns:

The result table.