RDD基本操做(Python)

RDD基本轉換運算 建立RDD最簡單的方式是使用SparkContext的parallelize方法shell intRDD=sc.parallelize([3,1,2,5,5]) intRDD.collect() 因爲spark的惰性,轉化操做並不會立刻執行,而collect()是一個「動做」,spark馬上執行,RDD轉換爲listapp 關於collect,在shell環境能夠直接顯示結果,
相關文章
相關標籤/搜索