pyflink.dataframe.DataFrame.filter

DataFrame.filter(predicate: Union[pyflink.table.expression.Expression, str, Callable[[pyflink.dataframe.dataframe.DataFrame], pyflink.table.expression.Expression]], **constraints) → pyflink.dataframe.dataframe.DataFrame

Filter rows based on a predicate.

Parameters

• predicate – Filter condition. Can be: - An Expression - A SQL string - A callable that takes the DataFrame and returns an Expression

• **constraints – Additional equality constraints as column=value pairs.

Returns

A new DataFrame with filtered rows.

Example::

>>> df.filter(col("a") > 10)
>>> df.filter("a > 10")                    # SQL string
>>> df.filter(col("a") > 10, b="hello")    # Mix predicate and constraints
>>> df.filter(lambda df: df["a"] > 10)