使用SparkSQL 和 Hive API 代码实现用户自定义函数UDF UDAF UDTF
UDAF例:SparkSQL 中继承Aggregator自定义UDAF函数:输入多行,返回一行 => 聚合函数 。 (Scala代码实现)import org.apache.spark.SparkConfimport org.apache.spark.sql.expressions.Aggregatorimport org.apache.spark.sql.{DataFrame, Encoder, Encoders, SparkSession, functions}//输入多行