(1)eclipse上创建Map/Reduce工程,命名为GeoMeanPro,在创建前,先把hive/lib目录下的jar包复制到hadoop/lib目录下面;
(2)在创建的工程上添加class,新建包com.hive.geomean.udaf,并在包下建立GeoMean.java;
(3)GeoMean.java代码为:
package com.hive.geomean.udaf;
import org.apache.hadoop.hive.ql.exec.UDAF;
import org.apache.hadoop.hive.ql.exec.UDAFEvaluator;
import org.apache.hadoop.io.IntWritable;
public class GeoMean extends UDAF {
public static class GeoMeanUDAFEval implements UDAFEvaluator {
最后
以上就是怕黑糖豆最近收集整理的关于Hive的UDAF编程:计算几何平均值的全部内容,更多相关Hive内容请搜索靠谱客的其他文章。
本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
发表评论 取消回复