pyflink.table.Table.add_columns#
- Table.add_columns(*fields: Union[str, pyflink.table.expression.Expression]) pyflink.table.table.Table [source]#
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.