pyflink.dataframe.dataframe.DataFrame.filter

DataFrame.filter(predicate: Expression | str | Callable[[DataFrame], Expression], **constraints) → 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)