pyflink.dataframe.DataFrame.drop_columns#

DataFrame.drop_columns(*columns: Union[str, pyflink.table.expression.Expression], strict: bool = True) → pyflink.dataframe.dataframe.DataFrame[source]#

Drop columns from the DataFrame.

Parameters

*columns – Column names or expressions to drop.
strict – If True, raise an error if a column doesn’t exist. If False, silently ignore non-existent columns.

Returns

A new DataFrame without the dropped columns.

Example::

>>> df.drop_columns("a", "b")
>>> df.drop_columns(col("a"), col("b"))
>>> df.drop_columns("nonexistent", strict=False)