抽样。
collectAsMap
返回键值在这个抽样到主字典。
笔记
这种方法应该只用于如果结果数据预计将小,因为所有数据加载到司机的记忆。
例子
> > >米=sc。并行化(((1,2),(3,4)))。collectAsMap()> > >米(1]2> > >米(3]4
以前的
pyspark.RDD.collect
下一个
pyspark.RDD.collectWithJobGroup