pyflink.table.Table.rename_columns

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