这也许是个愚蠢的问题，但我已经挣扎了很长时间了。它确实类似于这个问题，但我无法在我的代码中应用它（由于模式或作为一个函数）。
我想将一个flatmap（或map）转换函数传递给一个函数参数，然后将它代理给一个实际调用df.rdd.flatmap方法的策略函数。我会尽力解释的！

case class Order(id: String, totalValue: Double, freight: Double) 
case class Product(id: String, price: Double) 

... or any other case class, whatever one needs to transform a row into ...

实体类：

class Entity(path: String) = {
  ...
  def flatMap[T](mapFunction: (Row) => ArrayBuffer[T]): Entity = {
      this.getStrategy.flatMap[T](mapFunction)
      return this
  }
  def save(path: String): Unit = {
      ... write logic ...
  } 
}

实体的方法可能有不同的策略。实体策略如下：

abstract class EntityStrategy(private val entity: Entity,
                              private val spark: SparkSession) {
  ...
  def flatMap[T](mapFunction: (Row) => ArrayBuffer[T])
  def map[T](mapFunction: (Row) => T)
}

以及一个实体战略实施示例：

class SparkEntityStrategy(private val entity: Entity, private val spark: SparkSession)
  extends EntityStrategy(entity, spark) {
  ...
  override def map[T](mapFunction: Row => T): Unit = {
    val rdd = this.getData.rdd.map(f = mapFunction)
    this.dataFrame = this.spark.createDataFrame(rdd)
  }

  override def flatMap[T](mapFunction: (Row) => ArrayBuffer[T]): Unit = {
    var rdd = this.getData.rdd.flatMap(f = mapFunction)
    this.dataFrame = this.spark.createDataFrame(rdd)
  }
}

最后，我想创建一个flatmap/map函数并这样调用它：

def transformFlatMap(row: Row): ArrayBuffer[Order] = {
    var orders = new ArrayBuffer[Order]
    var _deliveries = row.getAs[Seq[Row]]("deliveries")
    _deliveries.foreach(_delivery => {
       var order = Order(
           id = row.getAs[String]("id"),
           totalValue = _delivery.getAs("totalAmount").asInstanceOf[Double])
      orders += order
    })
   return orders
}

val entity = new Entity("path")
entity.flatMap[Order](transformFlatMap).save("path")

当然，这是行不通的。我在sparkentitystrategy上出错了：
错误：（95，35）没有可用于t val rdd=this.getdata.rdd.map（f=mapfunction）的类标记
我试过添加一个 (implicit encoder: Encoder: T) 实体方法和战略方法，但这是不可能的。可能是做错了什么，因为我刚到斯卡拉。
如果我去掉“t”并通过一个实际的case类，一切都会正常。