pyspark.streaming.DStream.repartition

DStream。 重新分區 ( numPartitions:int )→pyspark.streaming.dstream.DStream(T]

返回一個新的DStream增加或減少程度的並行性。

以前的

pyspark.streaming.DStream.reduceByWindow

下一個

pyspark.streaming.DStream.rightOuterJoin