pyspark.streaming.DStream.filter# DStream.filter(f)[source]# Return a new DStream containing only the elements that satisfy predicate.