pyflink.dataframe.dataframe.DataFrame.rename_columns

DataFrame.rename_columns(*args, mapping: Dict[str, str] | Callable[[str], str] | None = None) → DataFrame

Rename columns.

Supports multiple input formats: - Dictionary mapping old names to new names - Callable that transforms column names - Two strings for single column rename - Multiple pairs of strings for multi-column rename

Parameters:

• *args – For column rename: - Single column: (old_name, new_name) - Multiple columns: (old1, new1, old2, new2, …)

• mapping – Rename mapping. Can be: - Dict[str, str]: {“old_name”: “new_name”} - Callable[[str], str]: lambda name: name.upper()

Returns:

A new DataFrame with renamed columns.

Example::

>>> df.rename_columns({"a": "id", "b": "value"})
>>> df.rename_columns("a", "id")                   # Single column
>>> df.rename_columns("a", "id", "b", "value")     # Multiple columns
>>> df.rename_columns(lambda name: name.upper())   # Transform all names