Hive中的UDF和UDAF是如何定义和使用的

在Hive中，用户定义的函数（UDF）和用户定义的聚合函数（UDAF）可以通过编写Java代码或使用Hive自定义函数语言（UDF/UDAF）来定义和实现。

要定义一个UDF，首先需要编写一个继承自Hive的UDF类的Java类，并实现evaluate方法。然后使用CREATE FUNCTioN语句在Hive中注册这个函数。

例如，下面是一个简单的UDF示例：

import org.apache.hadoop.hive.ql.exec.UDF;
import org.apache.hadoop.io.Text;

public class MyUDF extends UDF {
  public Text evaluate(Text input) {
    if (input == null) {
      return null;
    }
    return new Text(input.toString().toUpperCase());
  }
}

然后在Hive中注册这个UDF：

CREATE FUNCTION my_udf AS 'com.example.MyUDF';

要定义一个UDAF，需要编写一个继承自Hive的UDAF类的Java类，并实现evaluate方法来定义聚合逻辑。然后使用CREATE FUNCTION语句在Hive中注册这个聚合函数。

例如，下面是一个简单的UDAF示例：

import org.apache.hadoop.hive.ql.exec.UDAF;
import org.apache.hadoop.io.IntWritable;

public class MyUDAF extends UDAF {
  public static class MyUDAFEvaluator extends UDAFResolver2 {
    private IntWritable result;

    public MyUDAFEvaluator() {
      reset();
    }

    public void reset() {
      result = null;
    }

    public boolean iterate(IntWritable value) {
      if (value == null) {
        return true;
      }
      if (result == null) {
        result = new IntWritable(value.get());
      } else {
        result.set(result.get() + value.get());
      }
      return true;
    }

    public IntWritable terminatePartial() {
      return result;
    }

    public boolean merge(IntWritable other) {
      if (other == null) {
        return true;
      }
      if (result == null) {
        result = new IntWritable(other.get());
      } else {
        result.set(result.get() + other.get());
      }
      return true;
    }

    public IntWritable terminate() {
      return result;
    }
  }
}

然后在Hive中注册这个UDAF：

CREATE FUNCTION my_udaf AS 'com.example.MyUDAF';

使用定义好的UDF和UDAF函数，可以在Hive中执行查询，如：

SELECT my_udf(column_name) FROM table_name;
SELECT my_udaf(column_name) FROM table_name;