如何在 spark 中顺序执行？

如何解决如何在 spark 中顺序执行？

我正在使用 df.map 在每一行上进行转换来迭代数据帧。现在，当我构建我的包时，下面的代码 displayResults 将结果打印为 0，即它不采用每行转换后获得的值。我意识到 displayResults 与 map 方法并行运行。我怎样才能让这个方法调用等待 inputDataFrame.map 方法的完成。谢谢:)

class Obj{
  var total=_
  var avail=_
  def MyMethod(inputDataFrame: DataFrame): Unit={
    val finalvalue=inputDataFrame.map(r=>{
       //apply transformations on row
       total=r.getInt(0)+r.getInt(1)
       avail=helper(r)
    })
    displayResults(total,avail)
  }
  displayResults(total: Int,avail: Int): Unit={
    println("Results "+(avail/total))
  }
}