抽樣。
collectAsMap
返回鍵值在這個抽樣到主字典。
筆記
這種方法應該隻用於如果結果數據預計將小,因為所有數據加載到司機的記憶。
例子
> > >米=sc。並行化(((1,2),(3,4)))。collectAsMap()> > >米(1]2> > >米(3]4
以前的
pyspark.RDD.collect
下一個
pyspark.RDD.collectWithJobGroup