Spark UDFユーザー定義関数
クエリー文字列の長さを実現する関数をカスタマイズします.まず、テストのDataFrameを作成します.
関数名とパラメータタイプを含む関数を登録します.
カスタム関数を使用するには:
val spark = SparkSession.builder().master("local").appName("UDF").getOrCreate()
val nameList: List[String] = List[String]("zhangsan", "lisi", "wangwu", "zhaoliu", "tianqi")
import spark.implicits._
val nameDF: DataFrame = nameList.toDF("name")
nameDF.createOrReplaceTempView("students")
関数名とパラメータタイプを含む関数を登録します.
spark.udf.register("STRLEN",(name:String)=>{
name.length
})
// spark.udf.register("STRLEN",(name:String,i:Int)=>{
// name.length+i
// })
カスタム関数を使用するには:
spark.sql("select name ,STRLEN(name) as length from students order by length desc").show(100)
// spark.sql("select name ,STRLEN(name,10) as length from students order by length desc").show(100)