pyflink.datastream.functions.FilterFunction

class FilterFunction

A filter function is a predicate applied individually to each record. The predicate decides whether to keep the element, or to discard it.

The basic syntax for using a FilterFunction is as follows:

::

>>> ds = ...
>>> result = ds.filter(MyFilterFunction())

Note that the system assumes that the function does not modify the elements on which the predicate is applied. Violating this assumption can lead to incorrect results.

Methods

close()
filter(value)	The filter function that evaluates the predicate.
open(runtime_context)