pyflink.dataframe.dataframe.DataFrame.with_columns

DataFrame.with_columns(*exprs, **named_exprs) → DataFrame

Add multiple columns or replace existing columns.

Parameters:

• *exprs – Expressions with .alias() already applied.

• **named_exprs – Column name=expression pairs.

Returns:

A new DataFrame with the added/replaced columns.

Example::

>>> df.with_columns(
...     c=col("a") + col("b"),
...     d=col("a") * 2
... )
>>> df.with_columns(
...     (col("a") + col("b")).alias("c"),
...     (col("a") * 2).alias("d")
... )