pyspark.streaming.DStream.filter

DStream.filter(f)

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

pyspark.streaming.DStream.countByWindow pyspark.streaming.DStream.flatMap