pyspark.streaming.DStream.mapPartitions

DStream。 mapPartitions ( f:可調用的((Iterable(T]],Iterable(U]],preservesPartitioning:bool=假 )→pyspark.streaming.dstream.DStream(U]

返回一個新的DStream每個抽樣生成通過應用mapPartitions DStream每個抽樣()。

以前的

pyspark.streaming.DStream.map

下一個

pyspark.streaming.DStream.mapPartitionsWithIndex