# pyspark.streaming.DStream.filter¶

DStream.filter(f)[source]

Return a new DStream containing only the elements that satisfy predicate.