Spark----SparkSQL用户自定义函数

UDF 经过spark.udf功能用户能够自定义函数。sql 用户自定义UDF函数 scala> val df = spark.read.json("examples/src/main/resources/people.json") df: org.apache.spark.sql.DataFrame = [age: bigint, name: string] scala> df.show()

>>阅读原文<<