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