pyspark.streaming.DStream.flatMapValues#

DStream.flatMapValues(f)[source]#: Return a new DStream by applying a flatmap function to the value of each key-value pairs in this DStream without changing the key.