pyspark.streaming.DStream.partitionBy

DStream。 partitionBy ( numPartitions: int, partitionFunc:可調用的[[K], int] = <函數portable_hash > )→pyspark.streaming.dstream.DStream(元組(K,V] ]

返回一個副本的DStream每個抽樣分區使用指定的分割者。

以前的

pyspark.streaming.DStream.mapValues

下一個

pyspark.streaming.DStream.persist