DStream.
filter
Return a new DStream containing only the elements that satisfy predicate.
previous
pyspark.streaming.DStream.countByWindow
next
pyspark.streaming.DStream.flatMap