spark自定义hive的UDF/UDAF函数

自定义UDF函数 package com.ws.spark import org.apache.spark.sql.DataFrame import org.apache.spark.sql.hive.HiveContext import org.apache.spark.{SparkConf, SparkContext} object MyUDF{ def main(args: Array
相关文章
相关标签/搜索