pyspark.streaming.DStream.mapValues

DStream。 mapValues ( f:可調用的((V],U] )→pyspark.streaming.dstream.DStream(元組(K,U] ]

返回一個新的DStream通過應用一個函數映射到值的每一個鍵值對DStream不改變的關鍵。

以前的

pyspark.streaming.DStream.mapPartitionsWithIndex

下一個

pyspark.streaming.DStream.partitionBy