UDF 是我们用户可以自定义的函数，我们通过SparkSession对象来调用 udf 的 register（name：String，func（A1,A2,A3...）） 方法来注册一个我们自定义的函数。其中，name 是我们自定义的函数名称，func 是我们自定义的函数，它可以有很多个参数。 通过 UDF 函数，我们可以针对某一列数据或者某单元格数据进行针对的处理。 案例 1 定义一个函数，给 Andy 的 name 字段的值前 + "Name: "。 def main(args: Array[String]): Unit = { val conf = new SparkConf() conf.setAppName("spark sql udf") .setMaster("local[*]") val spark = SparkSession.builder().config(conf).getOrCreate() import spark.implicits._ val df = spark.read.json("data/sql/people.json")...
