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