Spark總結(三)——RDD的Action操做

一、foreach操做:對RDD中的每一個元素執行f函數操做,返回Unit。python def funOps1(): Unit = { var rdd1 = sc.parallelize(List(1, 2, 3, 5, 6)) rdd1.foreach(println _) } 源碼: web 二、saveAsTextFile操做:將數據輸出到hdfs上,將RDD中的每一個元素映射轉變
相關文章
相關標籤/搜索