pyflink.table.Table.rename_columns

Table.rename_columns(*fields: Expression) → Table

Renames existing columns. Similar to a field alias statement. The field expressions should be alias expressions, and only the existing fields can be renamed.

Example:

>>> tab.rename_columns(col('a').alias('a1'), col('b').alias('b1'))

Parameters:

fields – Column list string.

Returns:

The result table.