要使用 UDF 自定义函数与 Spark SQL,需要导入依赖包:

  • org.apache.spark:spark-sql_2.10:1.6.1
  • org.apache.spark:spark-hive_2.10:1.6.1