pyspark.RDD.partitionBy

抽樣。 partitionBy ( partitionFunc numPartitions:可選(int):可調用的[[K], int] = <函數portable_hash > )→pyspark.rdd.RDD(元組(K,V] ]

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

例子

> > >雙=sc。並行化([1,2,3,4,2,4,1])。地圖(λx:(x,x))> > >集=雙。partitionBy(2)。偷()。收集()> > >len(集(集(0])。十字路口(集(集(1))))0

以前的

pyspark.RDD.name

下一個

pyspark.RDD.persist