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()

>>阅读原文<<