pyflink.dataframe.dataframe.DataFrame.select

DataFrame.select(*columns, **projections) → DataFrame

Select columns from the DataFrame.

Supports multiple input formats: - String column names - Expression objects - Lists/tuples of column names or expressions - Keyword arguments for renaming columns

Parameters:

• *columns – Columns to select. Can be strings, Expressions, or lists.

• **projections – Column projections as name=expression. The name becomes the new column name.

Returns:

A new DataFrame with selected columns.

Example::

>>> df.select("a", "b")                    # Select columns by name
>>> df.select(col("a"), col("b"))          # Select with expressions
>>> df.select("a", c=col("a") + 1)         # Mix strings and kwargs
>>> df.select(["a", "b"])                  # List of column names
>>> df.select(x=col("a"), y=col("b"))      # Rename with kwargs