我想把数据的每一行的输入和retun输出作为一个映射。

def getV(str:String,colValues:Map[String,Any]):Any={
    var s= colValues.get("str") match {
      case Some(value) =>value
      case None =>None
    return s
  def setV(key:String,value:String,colValues:scala.collection.mutable.Map[String,Any]):Unit={
    colValues(key)=value
def returnNotEmptyCols_map(inputRow: Row): collection.mutable.Map[String,Any] = {
    implicit val formats = Serialization.formats(NoTypeHints)
    var colValues = inputRow.getValuesMap[Any](inputRow.schema.fieldNames)
    var mutMap = collection.mutable.Map(colValues.toSeq: _*)
    //Write my operations here------
    //print(getV("number",colValues))
    //setV("hey","there",mutMap)
    mutMap
    //return df
  }

然而，我面临的问题是，我使用udf从dataframe调用这个函数，因此结果输出是列格式的。

spark.udf.register("myFilterFunction", returnNotEmptyCols _)
    import spark.implicits._
    val df = Seq(