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