本文将展示如何创建一个蜂巢UDF,注册在火花,火花SQL查询并使用它。

这是一个需要一个蜂巢UDF长作为参数,并返回它的十六进制表示。

% scala org.apache.hadoop.hive.ql.exec进口。进口org.apache.hadoop.io UDF。LongWritable / /这个UDF需要很长整数,并将其转换为十六进制字符串。类ToHex延伸UDF {def评估(n: LongWritable):字符串= {(n) . map选项{num = > / /使用Scala字符串插值。这是最简单的方法,/ /类型安全的,不像String.format ()。f“0 x $ {num。}% x”} .getOrElse (" ")}}

注册功能:

% scala火花。sql(“创建临时函数to_hex com.ardentex.spark.hiveudf.ToHex”)

用你的注册功能和其他功能:

% scala火花。sql(“选择first_name、to_hex(代码)hex_code从人”)

你可以找到更多的例子和compilable代码示例蜂巢UDF项目。