DStream.filter(f)[source]#

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