pyspark.RDD.toLocalIterator¶

抽樣。 toLocalIterator ( prefetchPartitions:bool=假 )→迭代器(T] ¶

返回一個迭代器,包含所有的元素在這個抽樣。迭代器將使用盡可能多的內存分區最大抽樣。預取它可能消耗2最大的內存分區。

參數

例子

           > > >抽樣=sc。並行化(範圍(10))> > >(x為x在抽樣。toLocalIterator())(0,1,2,3,4,5,6,7,8,9)
          

以前的

pyspark.RDD.toDebugString

下一個

pyspark.RDD.top