直接上测试代码： import org.apache.spark.SparkConf import org.apache.spark.sql.SparkSession import org.apache.spark.sql.functions.{udf, _} import org.junit.{Assert, Test} import org.apache.spark.sql.types._...