pyflink.dataframe.DataFrame.drop

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

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)