在spark中，可以使用用户定义的函数 mapPartitions . 现在我的问题是我怎样才能把一个论点传给它。例如，现在我有这样的东西，叫做using rdd.mapPartitions(userdefinedFunc) .

def userdefinedFunc(iter: Iterator[(Long, Array[SAMRecord])]) : Iterator[(Long, Long)] = 
{
  val res = scala.collection.mutable.ArrayBuffer.empty[(Long, Long)]

  // Code here

  res.iterator
}

但是，我还希望有一个常量作为该用户定义函数的参数，例如，它如下所示。

def userdefinedFunc(iter: Iterator[(Long, Array[SAMRecord])], someConstant: Long) : 
 Iterator[(Long, Long)] = 
{
  val res = scala.collection.mutable.ArrayBuffer.empty[(Long, Long)]

  // Code here

  res.iterator
}

现在我如何用 mapPartitions . 如果我使用 rdd.mapPartitions(userdefinedFunc(someConstant)) .