pyspark.streaming.DStream.mapPartitionsWithIndex

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

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

以前的

pyspark.streaming.DStream.mapPartitions

下一個

pyspark.streaming.DStream.mapValues