pyflink.table.Table.filter#
- Table.filter(predicate: Union[str, pyflink.table.expression.Expression[bool]]) pyflink.table.table.Table[source]#
Filters out elements that don’t pass the filter predicate. Similar to a SQL WHERE clause.
Example:
>>> tab.filter(col('name') == 'Fred')
- Parameters
predicate – Predicate expression string.
- Returns
The result table.