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)