RDD基本操做(Python)

RDD基本转换运算 建立RDD最简单的方式是使用SparkContext的parallelize方法shell intRDD=sc.parallelize([3,1,2,5,5]) intRDD.collect() 因为spark的惰性,转化操做并不会立刻执行,而collect()是一个“动做”,spark马上执行,RDD转换为listapp 关于collect,在shell环境能够直接显示结果,
相关文章
相关标签/搜索