pyspark.streaming.DStream.flatMapValues

DStream. flatMapValues ( f : Callable [ [ V ] , Iterable [ U ] ] ) → pyspark.streaming.dstream.DStream [ Tuple [ K , U ] ] [source]

返回一个新的DStream，通过将flatmap函数应用于该DStream中每个键值对的值而不改变键。

上一篇

pyspark.streaming.DStream.flatMap

下一页

pyspark.streaming.DStream.foreachRDD