在Spark 2中,我使用的UDAF是这样的: case class ColumnBuilderUDAF(channels: Seq[String]) extends UserDefinedAggregateFunction在Spark3中,UDAF被弃用,应该使用Aggregator。所以我开始像这样移植它: case class ColumnBuilder(channels: Seq[String]) extends Aggregator[(String, Double), Array或者我仍然必须使用已弃用的UDAF