pyspark.streaming.DStream.filter

DStream.filter(f: Callable[[T], bool]) → pyspark.streaming.dstream.DStream[T]

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

previous

pyspark.streaming.DStream.countByWindow

next

pyspark.streaming.DStream.flatMap