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)