第五章_Spark核心编程_Rdd_行动算子_foreach

1.定义

  /*
* 1.定义
*     def foreach(f: T => Unit): Unit
* 2.功能
*     分布式遍历 RDD 中的每一个元素，调用指定函数
*     note : 在每个分区节点上,执行指定函数f
* */

2.示例

  object foreachTest extends App {

    val sparkconf: SparkConf = new SparkConf().setMaster("local").setAppName("distinctTest")

    val sc: SparkContext = new SparkContext(sparkconf)

    private val rdd = sc.makeRDD(List((1,"x"),(1,"x"),(2,"x"),(2,"x"),(2,"x")), 2)

    rdd.foreach(println(_))

    sc.stop()
  }