pyflink.table.Table.add_columns

Table.add_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. It will throw an exception if the added fields already exist.

Example:

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

Parameters:

fields – Column list string.

Returns:

The result table.