spark计算psi的udf函数

import org.apache.spark.SparkConf import org.apache.spark.rdd.RDD import org.apache.spark.sql.functions._ import org.apache.spark.sql.types.DoubleType import org.apache.spark.sql.{DataFrame, SparkSession, functions} object UDF extends App { def psi: ((Seq[Int], Int, Seq[Int], Int) => Double) =