pyspark.streaming.DStream.flatMapValues

DStream。 flatMapValues ( f:可调用的((V],Iterable(U]] )→pyspark.streaming.dstream.DStream(元组(K,U] ]

返回一个新的DStream flatmap函数应用到每个键值对的值在这个DStream不改变的关键。

以前的

pyspark.streaming.DStream.flatMap

下一个

pyspark.streaming.DStream.foreachRDD