文章显示如何创建HiveUDF并注册Spark使用SparkSQL查询

iveUDF使用长长并返回十六进制表示法

scala导入org.apache.hadoop.hive.ql.exec.UDF导入org.apache.hadoop.io.LongWritiTohex类扩展UDF {def评价(n:LongWriteble:string={Opt-n).map{num+/使用Scala字符串插值最便捷方式 //类型安全 不像String.formatf0x${num.getx}.getOr Else

注册函数 :

scalaspark.sql

函数使用为任何其他注册函数

scalaspark.sql

更多例子和可编译代码样本HiveUDF项目.