udf 从hive表取数

UDF全称User-Defined Function，即用户自定义函数，在Hive中是一种用于处理非内置操作的方式。当你需要从Hive表中获取数据并执行特定的复杂计算，而Hive的标准SQL无法直接满足时，你可以创建一个UDF。
在Hive中，你可以编写Java、Python或其他支持的语言（如Scala或Python UDF插件）实现你的函数，然后注册这个函数到Hive的元存储中。这样，你在HQL查询中就可以像调用普通函数一样引用它，并利用这个函数来从表中提取数据。
例如，假设你想计算某个字段的平均值，但Hive本身没有现成的AVG函数，这时可以创建一个Java UDF来完成计算：
import org.apache.hadoop.hive.ql.exec.UDF;
import org.apache.hadoop.io.IntWritable;

public class AverageCalculator extends UDF {
public IntWritable evaluate(Double... values) {
int sum = 0;
for (Double value : values) {
sum += value;
}
return new IntWritable(sum / values.length);
}
}

// 注册函数
ADD FILE path_to_your_average_calculator.jar; // 加载jar文件
CREATE TEMPORARY FUNCTION average AS 'com.example.AverageCalculator';

-- 使用UDF查询
SELECT average(column_name) FROM table_name;
登录后复制