spark foreach

foreach 是一个action算子,不会触发shuffle

读取数据后,查看idea提示,foreach算子要求输入一个函数,这个函数的输入和数据相关(本次是String类型的变量),返回值为空。

需求:读取数据,利用foreach算子,输入一个函数,输出时在每个数据的首部加一个字符串head。

解决方案一:

data.foreach(fun)
    def fun(line:String):Unit={
      println("head"+line)
    }

解决方案二:

 data.map(x=>{"head"+x}).foreach(println)
原文地址:https://www.cnblogs.com/students/p/14215509.html