hive中如何实现自定义的count呢？

最近学习hive写udaf，想实现自定义count，判断如果字段为1就计数，代码如下：

<P> package com.job;</P>
<P>import org.apache.hadoop.hive.ql.exec.UDAF;
import org.apache.hadoop.hive.ql.exec.UDAFEvaluator;
import org.apache.hadoop.io.IntWritable;</P>
<P>
public class MaxiNumber extends UDAF{</P>
<P> public static class MaxiNumberIntUDAFEvaluator implements UDAFEvaluator{
  
  private IntWritable result;
  @Override
  public void init() {
   result=null;
  }
  
  public boolean iterate(IntWritable value){
   if(null == value){
    return false;
   }
   else if(null == result){
    result=new IntWritable(0);
    return true;
   }
   else{</P>
<P>      if(value.get()==1){
            result.set(result.get()+1);</P>
<P>      }
    return true;
   }
  }
  
  public IntWritable terminatePartial(){
   return result;
  }
  
  public boolean merge(IntWritable other){
   return iterate(other);
  }
  
  public IntWritable terminate(){
   return result;
  }
 }</P>
<P>}
</P>
复制代码

为什么跑出来结果都是1呢？

这是从哪里复制的哦，还带有html

public boolean iterate(IntWritable value){
   if(null == value){
    return false;
   }
   else if(null == result){
    result=new IntWritable(0);
    return true;
   }
   else{</P>
      if(value.get()==1){
            result.set(result.get()+1);
      }
    return true;
   }
  }

只加1了，但是没有赋值

muyannian 发表于 2014-10-10 17:45
public boolean iterate(IntWritable value){
   if(null == value){
    return false;

  result.set只是数据类型转换， 查看hadoop数据类型及Java数据类型的转换

已经解决了，谢谢
另外发现hive也支持类似CASE的高级过滤，很方便

luo3601721 发表于 2014-10-13 21:41
已经解决了，谢谢
另外发现hive也支持类似CASE的高级过滤，很方便

解决啦啊，真好。其实我就只懂那么点，能不能贴出来，大家学习一下。

最后是看hive的count源码仿造来实现的
实际生产环境中用的高级过滤，比如count(CASE WHEN plat=1 THEN u ELSE NULL END)解决一些问题的